Uses of Class
org.apache.hadoop.hbase.tool.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
Modifier and TypeClassDescriptionstatic class
Deprecated.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
Modifier and TypeMethodDescriptionprivate 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
Modifier 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.Modifier 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.Modifier and TypeMethodDescriptionprotected 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.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 HFilesvoid
LoadIncrementalHFiles.prepareHFileQueue
(Map<byte[], List<org.apache.hadoop.fs.Path>> map, Table table, Deque<LoadIncrementalHFiles.LoadQueueItem> queue, boolean silence) Deprecated.Prepare a collection ofLoadIncrementalHFiles.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 ofLoadIncrementalHFiles.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 ofLoadIncrementalHFiles.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.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 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.