Uses of Class
org.apache.hadoop.hbase.tool.LoadIncrementalHFiles.LoadQueueItem
Packages that use LoadIncrementalHFiles.LoadQueueItem
Package
Description
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
-
Uses of LoadIncrementalHFiles.LoadQueueItem in org.apache.hadoop.hbase.mapreduce
Subclasses of LoadIncrementalHFiles.LoadQueueItem in org.apache.hadoop.hbase.mapreduceModifier and TypeClassDescriptionstatic classDeprecated.As of release 2.0.0, this will be removed in HBase 3.0.0. -
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.LoadQueueItemModifier and TypeMethodDescriptionprivate voidHFileReplicator.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.LoadQueueItemModifier and TypeMethodDescriptionLoadIncrementalHFiles.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.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.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.LoadIncrementalHFiles.performBulkLoad(Admin admin, Table table, RegionLocator regionLocator, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, ExecutorService pool, SecureBulkLoadClient secureClient, boolean copyFile) Deprecated.Deprecated.Perform bulk load on the given table.LoadIncrementalHFiles.run(Map<byte[], List<org.apache.hadoop.fs.Path>> family2Files, TableName tableName) Deprecated.Perform bulk load on the given table.protected final Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> Deprecated.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.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.Methods in org.apache.hadoop.hbase.tool with parameters of type LoadIncrementalHFiles.LoadQueueItemModifier and TypeMethodDescriptionprotected 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.LoadQueueItemModifier and TypeMethodDescriptionprotected ClientServiceCallable<byte[]>LoadIncrementalHFiles.buildClientServiceCallable(Connection conn, TableName tableName, byte[] first, Collection<LoadIncrementalHFiles.LoadQueueItem> lqis, boolean copyFile) Deprecated.protected voidLoadIncrementalHFiles.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 voidLoadIncrementalHFiles.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 voidLoadIncrementalHFiles.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 booleanLoadIncrementalHFiles.checkHFilesCountPerRegionPerFamily(org.apache.hbase.thirdparty.com.google.common.collect.Multimap<ByteBuffer, LoadIncrementalHFiles.LoadQueueItem> regionGroups) Deprecated.private voidLoadIncrementalHFiles.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 voidLoadIncrementalHFiles.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.voidLoadIncrementalHFiles.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.voidLoadIncrementalHFiles.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.LoadIncrementalHFiles.performBulkLoad(Admin admin, Table table, RegionLocator regionLocator, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, ExecutorService pool, SecureBulkLoadClient secureClient, boolean copyFile) Deprecated.private voidLoadIncrementalHFiles.populateLoadQueue(Deque<LoadIncrementalHFiles.LoadQueueItem> ret, Map<byte[], List<org.apache.hadoop.fs.Path>> map) Deprecated.Populate the Queue with given HFilesvoidLoadIncrementalHFiles.prepareHFileQueue(Map<byte[], List<org.apache.hadoop.fs.Path>> map, Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean silence) Deprecated.Prepare a collection ofLoadIncrementalHFiles.LoadQueueItemfrom list of source hfiles contained in the passed directory and validates whether the prepared queue has all the valid table column families in it.voidLoadIncrementalHFiles.prepareHFileQueue(org.apache.hadoop.fs.Path hfilesDir, Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean validateHFile) Deprecated.Prepare a collection ofLoadIncrementalHFiles.LoadQueueItemfrom list of source hfiles contained in the passed directory and validates whether the prepared queue has all the valid table column families in it.voidLoadIncrementalHFiles.prepareHFileQueue(org.apache.hadoop.fs.Path hfilesDir, Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean validateHFile, boolean silence) Deprecated.Prepare a collection ofLoadIncrementalHFiles.LoadQueueItemfrom 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.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.private voidLoadIncrementalHFiles.validateFamiliesInHFiles(Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean silence) Deprecated.Checks whether there is any invalid family name in HFiles to be bulk loaded.