Uses of Class
org.apache.hadoop.hbase.tool.LoadIncrementalHFiles.LoadQueueItem

Packages that use LoadIncrementalHFiles.LoadQueueItem

Package	Description
org.apache.hadoop.hbase.mapreduce	Provides HBase MapReduce Input/OutputFormats, a table indexing MapReduce job, and utility methods.
org.apache.hadoop.hbase.replication.regionserver
org.apache.hadoop.hbase.tool

Uses of LoadIncrementalHFiles.LoadQueueItem in org.apache.hadoop.hbase.mapreduce

Subclasses of LoadIncrementalHFiles.LoadQueueItem in org.apache.hadoop.hbase.mapreduce

Modifier and Type	Class and Description
static class	LoadIncrementalHFiles.LoadQueueItem Deprecated. As of release 2.0.0, this will be removed in HBase 3.0.0. Use LoadIncrementalHFiles.LoadQueueItem instead.

Uses of LoadIncrementalHFiles.LoadQueueItem in org.apache.hadoop.hbase.replication.regionserver

Method parameters in org.apache.hadoop.hbase.replication.regionserver with type arguments of type LoadIncrementalHFiles.LoadQueueItem

Modifier and Type	Method and Description
private void	HFileReplicator.doBulkLoad(LoadIncrementalHFiles loadHFiles, Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, RegionLocator locator, int maxRetries)

Uses of LoadIncrementalHFiles.LoadQueueItem in org.apache.hadoop.hbase.tool

Methods in org.apache.hadoop.hbase.tool that return types with arguments of type LoadIncrementalHFiles.LoadQueueItem

Modifier and Type	Method and Description
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>	LoadIncrementalHFiles.doBulkLoad(Map<byte[],List<org.apache.hadoop.fs.Path>> map, Admin admin, Table table, RegionLocator regionLocator, boolean silence, boolean copyFile) Deprecated. Perform a bulk load of the given directory into the given pre-existing table.
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>	LoadIncrementalHFiles.doBulkLoad(org.apache.hadoop.fs.Path hfofDir, Admin admin, Table table, RegionLocator regionLocator) Deprecated. Perform a bulk load of the given directory into the given pre-existing table.
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>	LoadIncrementalHFiles.doBulkLoad(org.apache.hadoop.fs.Path hfofDir, Admin admin, Table table, RegionLocator regionLocator, boolean silence, boolean copyFile) Deprecated. Perform a bulk load of the given directory into the given pre-existing table.
private Map<byte[],Collection<LoadIncrementalHFiles.LoadQueueItem>>	LoadIncrementalHFiles.groupByFamilies(Collection<LoadIncrementalHFiles.LoadQueueItem> itemsInRegion) Deprecated.
protected Pair<List<LoadIncrementalHFiles.LoadQueueItem>,String>	LoadIncrementalHFiles.groupOrSplit(org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, LoadIncrementalHFiles.LoadQueueItem item, Table table, Pair<byte[][],byte[][]> startEndKeys) Deprecated. Attempt to assign the given load queue item into its target region group.
private Pair<org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem>,Set<String>>	LoadIncrementalHFiles.groupOrSplitPhase(Table table, ExecutorService pool, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, Pair<byte[][],byte[][]> startEndKeys) Deprecated.
private Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>	LoadIncrementalHFiles.performBulkLoad(Admin admin, Table table, RegionLocator regionLocator, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, ExecutorService pool, SecureBulkLoadClient secureClient, boolean copyFile) Deprecated.
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>	LoadIncrementalHFiles.run(Map<byte[],List<org.apache.hadoop.fs.Path>> family2Files, TableName tableName) Deprecated. Perform bulk load on the given table.
protected Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>	LoadIncrementalHFiles.run(org.apache.hadoop.fs.Path hfofDir, TableName tableName) Deprecated.
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>	LoadIncrementalHFiles.run(String hfofDir, TableName tableName) Deprecated. Perform bulk load on the given table.
private List<LoadIncrementalHFiles.LoadQueueItem>	LoadIncrementalHFiles.splitStoreFile(LoadIncrementalHFiles.LoadQueueItem item, Table table, byte[] startKey, byte[] splitKey) Deprecated.
protected List<LoadIncrementalHFiles.LoadQueueItem>	LoadIncrementalHFiles.tryAtomicRegionLoad(ClientServiceCallable<byte[]> serviceCallable, TableName tableName, byte[] first, Collection<LoadIncrementalHFiles.LoadQueueItem> lqis) Deprecated. as of release 2.3.0. Use BulkLoadHFiles instead.
protected List<LoadIncrementalHFiles.LoadQueueItem>	LoadIncrementalHFiles.tryAtomicRegionLoad(Connection conn, TableName tableName, byte[] first, Collection<LoadIncrementalHFiles.LoadQueueItem> lqis, boolean copyFile) Deprecated. as of release 2.3.0. Use BulkLoadHFiles instead.

Methods in org.apache.hadoop.hbase.tool with parameters of type LoadIncrementalHFiles.LoadQueueItem

Modifier and Type	Method and Description
protected Pair<List<LoadIncrementalHFiles.LoadQueueItem>,String>	LoadIncrementalHFiles.groupOrSplit(org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, LoadIncrementalHFiles.LoadQueueItem item, Table table, Pair<byte[][],byte[][]> startEndKeys) Deprecated. Attempt to assign the given load queue item into its target region group.
private List<LoadIncrementalHFiles.LoadQueueItem>	LoadIncrementalHFiles.splitStoreFile(LoadIncrementalHFiles.LoadQueueItem item, Table table, byte[] startKey, byte[] splitKey) Deprecated.

Method parameters in org.apache.hadoop.hbase.tool with type arguments of type LoadIncrementalHFiles.LoadQueueItem

Modifier and Type	Method and Description
protected ClientServiceCallable<byte[]>	LoadIncrementalHFiles.buildClientServiceCallable(Connection conn, TableName tableName, byte[] first, Collection<LoadIncrementalHFiles.LoadQueueItem> lqis, boolean copyFile) Deprecated.
protected void	LoadIncrementalHFiles.bulkLoadPhase(Table table, Connection conn, ExecutorService pool, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, boolean copyFile, Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> item2RegionMap) Deprecated. This takes the LQI's grouped by likely regions and attempts to bulk load them.
protected void	LoadIncrementalHFiles.bulkLoadPhase(Table table, Connection conn, ExecutorService pool, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, boolean copyFile, Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> item2RegionMap) Deprecated. This takes the LQI's grouped by likely regions and attempts to bulk load them.
protected void	LoadIncrementalHFiles.bulkLoadPhase(Table table, Connection conn, ExecutorService pool, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, boolean copyFile, Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> item2RegionMap) Deprecated. This takes the LQI's grouped by likely regions and attempts to bulk load them.
private boolean	LoadIncrementalHFiles.checkHFilesCountPerRegionPerFamily(org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups) Deprecated.
private void	LoadIncrementalHFiles.cleanup(Admin admin, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, ExecutorService pool, SecureBulkLoadClient secureClient) Deprecated.
private Map<BulkLoadHFiles.LoadQueueItem,ByteBuffer>	BulkLoadHFilesTool.convert(Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> map)
private void	LoadIncrementalHFiles.discoverLoadQueue(Deque<LoadIncrementalHFiles.LoadQueueItem> ret, org.apache.hadoop.fs.Path hfofDir, boolean validateHFile) Deprecated. Walk the given directory for all HFiles, and return a Queue containing all such files.
private Map<byte[],Collection<LoadIncrementalHFiles.LoadQueueItem>>	LoadIncrementalHFiles.groupByFamilies(Collection<LoadIncrementalHFiles.LoadQueueItem> itemsInRegion) Deprecated.
protected Pair<List<LoadIncrementalHFiles.LoadQueueItem>,String>	LoadIncrementalHFiles.groupOrSplit(org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, LoadIncrementalHFiles.LoadQueueItem item, Table table, Pair<byte[][],byte[][]> startEndKeys) Deprecated. Attempt to assign the given load queue item into its target region group.
private Pair<org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem>,Set<String>>	LoadIncrementalHFiles.groupOrSplitPhase(Table table, ExecutorService pool, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, Pair<byte[][],byte[][]> startEndKeys) Deprecated.
void	LoadIncrementalHFiles.loadHFileQueue(Table table, Connection conn, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, Pair<byte[][],byte[][]> startEndKeys) Deprecated. Used by the replication sink to load the hfiles from the source cluster.
void	LoadIncrementalHFiles.loadHFileQueue(Table table, Connection conn, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, Pair<byte[][],byte[][]> startEndKeys, boolean copyFile) Deprecated. Used by the replication sink to load the hfiles from the source cluster.
private Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>	LoadIncrementalHFiles.performBulkLoad(Admin admin, Table table, RegionLocator regionLocator, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, ExecutorService pool, SecureBulkLoadClient secureClient, boolean copyFile) Deprecated.
private void	LoadIncrementalHFiles.populateLoadQueue(Deque<LoadIncrementalHFiles.LoadQueueItem> ret, Map<byte[],List<org.apache.hadoop.fs.Path>> map) Deprecated. Populate the Queue with given HFiles
void	LoadIncrementalHFiles.prepareHFileQueue(Map<byte[],List<org.apache.hadoop.fs.Path>> map, Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean silence) Deprecated. Prepare a collection of LoadIncrementalHFiles.LoadQueueItem from list of source hfiles contained in the passed directory and validates whether the prepared queue has all the valid table column families in it.
void	LoadIncrementalHFiles.prepareHFileQueue(org.apache.hadoop.fs.Path hfilesDir, Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean validateHFile) Deprecated. Prepare a collection of LoadIncrementalHFiles.LoadQueueItem from list of source hfiles contained in the passed directory and validates whether the prepared queue has all the valid table column families in it.
void	LoadIncrementalHFiles.prepareHFileQueue(org.apache.hadoop.fs.Path hfilesDir, Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean validateHFile, boolean silence) Deprecated. Prepare a collection of LoadIncrementalHFiles.LoadQueueItem from list of source hfiles contained in the passed directory and validates whether the prepared queue has all the valid table column families in it.
protected List<LoadIncrementalHFiles.LoadQueueItem>	LoadIncrementalHFiles.tryAtomicRegionLoad(ClientServiceCallable<byte[]> serviceCallable, TableName tableName, byte[] first, Collection<LoadIncrementalHFiles.LoadQueueItem> lqis) Deprecated. as of release 2.3.0. Use BulkLoadHFiles instead.
protected List<LoadIncrementalHFiles.LoadQueueItem>	LoadIncrementalHFiles.tryAtomicRegionLoad(Connection conn, TableName tableName, byte[] first, Collection<LoadIncrementalHFiles.LoadQueueItem> lqis, boolean copyFile) Deprecated. as of release 2.3.0. Use BulkLoadHFiles instead.
private void	LoadIncrementalHFiles.validateFamiliesInHFiles(Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean silence) Deprecated. Checks whether there is any invalid family name in HFiles to be bulk loaded.