@InterfaceAudience.Public public interface BulkLoadHFiles
HFileOutputFormat
into an existing table
programmatically. Not thread safe.Modifier and Type | Interface and Description |
---|---|
static class |
BulkLoadHFiles.LoadQueueItem
Represents an HFile waiting to be loaded.
|
Modifier and Type | Field and Description |
---|---|
static String |
ALWAYS_COPY_FILES |
static String |
ASSIGN_SEQ_IDS |
static String |
BULK_LOAD_HFILES_BY_FAMILY
HBASE-24221 Support bulkLoadHFile by family to avoid long time waiting of bulkLoadHFile because
of compacting at server side
|
static String |
CREATE_TABLE_CONF_KEY |
static String |
IGNORE_UNMATCHED_CF_CONF_KEY |
static String |
MAX_FILES_PER_REGION_PER_FAMILY |
static String |
RETRY_ON_IO_EXCEPTION |
Modifier and Type | Method and Description |
---|---|
Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer> |
bulkLoad(TableName tableName,
Map<byte[],List<org.apache.hadoop.fs.Path>> family2Files)
Perform a bulk load of the given directory into the given pre-existing table.
|
Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer> |
bulkLoad(TableName tableName,
org.apache.hadoop.fs.Path dir)
Perform a bulk load of the given directory into the given pre-existing table.
|
static BulkLoadHFiles |
create(org.apache.hadoop.conf.Configuration conf) |
static final String RETRY_ON_IO_EXCEPTION
static final String MAX_FILES_PER_REGION_PER_FAMILY
static final String ASSIGN_SEQ_IDS
static final String CREATE_TABLE_CONF_KEY
static final String IGNORE_UNMATCHED_CF_CONF_KEY
static final String ALWAYS_COPY_FILES
static final String BULK_LOAD_HFILES_BY_FAMILY
Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer> bulkLoad(TableName tableName, Map<byte[],List<org.apache.hadoop.fs.Path>> family2Files) throws TableNotFoundException, IOException
tableName
- the table to load intofamily2Files
- map of family to List of hfilesTableNotFoundException
- if table does not yet existIOException
Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer> bulkLoad(TableName tableName, org.apache.hadoop.fs.Path dir) throws TableNotFoundException, IOException
tableName
- the table to load intodir
- the directory that was provided as the output path of a job using
HFileOutputFormat
TableNotFoundException
- if table does not yet existIOException
static BulkLoadHFiles create(org.apache.hadoop.conf.Configuration conf)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.