http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3b220124/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.BulkHFileVisitor.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.BulkHFileVisitor.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.BulkHFileVisitor.html deleted file mode 100644 index 0398be6..0000000 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.BulkHFileVisitor.html +++ /dev/null @@ -1,181 +0,0 @@ - - - - - - -Uses of Interface org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.BulkHFileVisitor (Apache HBase 3.0.0-SNAPSHOT API) - - - - - - - -
- - -
Skip navigation links
- - - - -
- - -
-

Uses of Interface
org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.BulkHFileVisitor

-
-
- -
- -
- - -
Skip navigation links
- - - - -
- - -

Copyright © 2007–2017 The Apache Software Foundation. All rights reserved.

- - http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3b220124/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.LoadQueueItem.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.LoadQueueItem.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.LoadQueueItem.html index c48b7ca..0f61e70 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.LoadQueueItem.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.LoadQueueItem.html @@ -89,10 +89,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. - -org.apache.hadoop.hbase.replication.regionserver -  - @@ -102,19 +98,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods.

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

- - - - - - - - - - - - -
Fields in org.apache.hadoop.hbase.mapreduce with type parameters of type LoadIncrementalHFiles.LoadQueueItem 
Modifier and TypeField and Description
private Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>LoadIncrementalHFiles.retValue 
@@ -123,276 +106,12 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods. - - - - - - - - - - - - - - - - - - - - - - -
Methods in org.apache.hadoop.hbase.mapreduce that return types with arguments of type LoadIncrementalHFiles.LoadQueueItem 
protected Pair<List<LoadIncrementalHFiles.LoadQueueItem>,String>LoadIncrementalHFiles.groupOrSplit(org.apache.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, - LoadIncrementalHFiles.LoadQueueItem item, - Table table, - Pair<byte[][],byte[][]> startEndKeys) -
Attempt to assign the given load queue item into its target region group.
-
private Pair<org.apache.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem>,Set<String>>LoadIncrementalHFiles.groupOrSplitPhase(Table table, - ExecutorService pool, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - Pair<byte[][],byte[][]> startEndKeys) 
(package private) Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>LoadIncrementalHFiles.performBulkLoad(Admin admin, - Table table, - RegionLocator regionLocator, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - ExecutorService pool, - SecureBulkLoadClient secureClient, - boolean copyFile) 
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> LoadIncrementalHFiles.run(String dirPath, Map<byte[],List<org.apache.hadoop.fs.Path>> map, - TableName tableName) 
protected List<LoadIncrementalHFiles.LoadQueueItem>LoadIncrementalHFiles.splitStoreFile(LoadIncrementalHFiles.LoadQueueItem item, - Table table, - byte[] startKey, - byte[] splitKey) 
protected List<LoadIncrementalHFiles.LoadQueueItem>LoadIncrementalHFiles.tryAtomicRegionLoad(ClientServiceCallable<byte[]> serviceCallable, - TableName tableName, - byte[] first, - Collection<LoadIncrementalHFiles.LoadQueueItem> lqis) -
Attempts to do an atomic load of many hfiles into a region.
-
- - - - - - - - - - - - - - - - -
Methods in org.apache.hadoop.hbase.mapreduce with parameters of type LoadIncrementalHFiles.LoadQueueItem 
Modifier and TypeMethod and Description
protected Pair<List<LoadIncrementalHFiles.LoadQueueItem>,String>LoadIncrementalHFiles.groupOrSplit(org.apache.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, - LoadIncrementalHFiles.LoadQueueItem item, - Table table, - Pair<byte[][],byte[][]> startEndKeys) -
Attempt to assign the given load queue item into its target region group.
-
protected List<LoadIncrementalHFiles.LoadQueueItem>LoadIncrementalHFiles.splitStoreFile(LoadIncrementalHFiles.LoadQueueItem item, - Table table, - byte[] startKey, - byte[] splitKey) 
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
Method parameters in org.apache.hadoop.hbase.mapreduce with type arguments of type LoadIncrementalHFiles.LoadQueueItem 
Modifier and TypeMethod and Description
protected ClientServiceCallable<byte[]>LoadIncrementalHFiles.buildClientServiceCallable(Connection conn, - TableName tableName, - byte[] first, - Collection<LoadIncrementalHFiles.LoadQueueItem> lqis, - boolean copyFile) 
protected voidLoadIncrementalHFiles.bulkLoadPhase(Table table, - Connection conn, - ExecutorService pool, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - org.apache.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, - boolean copyFile, - Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> item2RegionMap) -
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.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, - boolean copyFile, - Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> item2RegionMap) -
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.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, - boolean copyFile, - Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> item2RegionMap) -
This takes the LQI's grouped by likely regions and attempts to bulk load - them.
-
private booleanLoadIncrementalHFiles.checkHFilesCountPerRegionPerFamily(org.apache.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups) 
(package private) voidLoadIncrementalHFiles.cleanup(Admin admin, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - ExecutorService pool, - SecureBulkLoadClient secureClient) 
private voidLoadIncrementalHFiles.discoverLoadQueue(Deque<LoadIncrementalHFiles.LoadQueueItem> ret, - org.apache.hadoop.fs.Path hfofDir, - boolean validateHFile) -
Walk the given directory for all HFiles, and return a Queue - containing all such files.
-
protected Pair<List<LoadIncrementalHFiles.LoadQueueItem>,String>LoadIncrementalHFiles.groupOrSplit(org.apache.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem> regionGroups, - LoadIncrementalHFiles.LoadQueueItem item, - Table table, - Pair<byte[][],byte[][]> startEndKeys) -
Attempt to assign the given load queue item into its target region group.
-
private Pair<org.apache.hadoop.hbase.shaded.com.google.common.collect.Multimap<ByteBuffer,LoadIncrementalHFiles.LoadQueueItem>,Set<String>>LoadIncrementalHFiles.groupOrSplitPhase(Table table, - ExecutorService pool, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - Pair<byte[][],byte[][]> startEndKeys) 
voidLoadIncrementalHFiles.loadHFileQueue(Table table, - Connection conn, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - Pair<byte[][],byte[][]> startEndKeys) -
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) -
Used by the replication sink to load the hfiles from the source cluster.
-
(package private) Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer>LoadIncrementalHFiles.performBulkLoad(Admin admin, - Table table, - RegionLocator regionLocator, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - ExecutorService pool, - SecureBulkLoadClient secureClient, - boolean copyFile) 
private voidLoadIncrementalHFiles.populateLoadQueue(Deque<LoadIncrementalHFiles.LoadQueueItem> ret, - Map<byte[],List<org.apache.hadoop.fs.Path>> map) 
voidLoadIncrementalHFiles.prepareHFileQueue(Map<byte[],List<org.apache.hadoop.fs.Path>> map, - Table table, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - boolean silence) -
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.
-
voidLoadIncrementalHFiles.prepareHFileQueue(org.apache.hadoop.fs.Path hfilesDir, - Table table, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - boolean validateHFile) -
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.
-
voidLoadIncrementalHFiles.prepareHFileQueue(org.apache.hadoop.fs.Path hfilesDir, - Table table, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - boolean validateHFile, - boolean silence) -
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) -
Attempts to do an atomic load of many hfiles into a region.
-
private voidLoadIncrementalHFiles.validateFamiliesInHFiles(Table table, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - boolean silence) -
Checks whether there is any invalid family name in HFiles to be bulk loaded.
-
- -
  • - - -

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

    - - - - - - - - - - + TableName tableName) +
    Deprecated. 
    Method parameters in org.apache.hadoop.hbase.replication.regionserver with type arguments of type LoadIncrementalHFiles.LoadQueueItem 
    Modifier and TypeMethod and Description
    private voidHFileReplicator.doBulkLoad(LoadIncrementalHFiles loadHFiles, - Table table, - Deque<LoadIncrementalHFiles.LoadQueueItem> queue, - RegionLocator locator, - int maxRetries) 
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3b220124/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.html index fd5d9df..7edba2d 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/class-use/LoadIncrementalHFiles.html @@ -72,73 +72,7 @@

    Uses of Class
    org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles

    -
    - -
    +
    No usage of org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3b220124/devapidocs/org/apache/hadoop/hbase/mapreduce/package-frame.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-frame.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-frame.html index 5b50089..9fa0d0d 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-frame.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-frame.html @@ -13,7 +13,6 @@

    Interfaces

    Classes

    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3b220124/devapidocs/org/apache/hadoop/hbase/mapreduce/package-summary.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-summary.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-summary.html index ecf9362..7522cc1 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-summary.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-summary.html @@ -88,10 +88,6 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods.
    -LoadIncrementalHFiles.BulkHFileVisitor<TFamily> -  - - VisibilityExpressionResolver
    Interface to convert visibility expressions into Tags for storing along with Cells in HFiles.
    @@ -323,14 +319,14 @@ Input/OutputFormats, a table indexing MapReduce job, and utility methods.
    LoadIncrementalHFiles - -
    Tool to load the output of HFileOutputFormat into an existing table.
    +Deprecated +
    As of release 2.0.0, this will be removed in HBase 3.0.0.
    LoadIncrementalHFiles.LoadQueueItem - -
    Represents an HFile waiting to be loaded.
    +Deprecated +
    As of release 2.0.0, this will be removed in HBase 3.0.0.
    http://git-wip-us.apache.org/repos/asf/hbase-site/blob/3b220124/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html ---------------------------------------------------------------------- diff --git a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html index 8a3937c..588fdf0 100644 --- a/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html +++ b/devapidocs/org/apache/hadoop/hbase/mapreduce/package-tree.html @@ -91,7 +91,11 @@
  • org.apache.hadoop.hbase.mapreduce.Import (implements org.apache.hadoop.util.Tool)
  • org.apache.hadoop.hbase.mapreduce.ImportTsv (implements org.apache.hadoop.util.Tool)
  • org.apache.hadoop.hbase.mapreduce.IndexBuilder (implements org.apache.hadoop.util.Tool)
  • -
  • org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles (implements org.apache.hadoop.util.Tool)
  • +
  • org.apache.hadoop.hbase.tool.LoadIncrementalHFiles (implements org.apache.hadoop.util.Tool) + +
  • org.apache.hadoop.hbase.mapreduce.ResultSerialization (implements org.apache.hadoop.io.serializer.Serialization<T>)
  • org.apache.hadoop.hbase.mapreduce.RowCounter (implements org.apache.hadoop.util.Tool)
  • org.apache.hadoop.hbase.mapreduce.SampleUploader (implements org.apache.hadoop.util.Tool)
  • @@ -147,7 +151,11 @@
  • org.apache.hadoop.hbase.mapreduce.KeyValueSerialization (implements org.apache.hadoop.io.serializer.Serialization<T>)
  • org.apache.hadoop.hbase.mapreduce.KeyValueSerialization.KeyValueDeserializer (implements org.apache.hadoop.io.serializer.Deserializer<T>)
  • org.apache.hadoop.hbase.mapreduce.KeyValueSerialization.KeyValueSerializer (implements org.apache.hadoop.io.serializer.Serializer<T>)
  • +
  • org.apache.hadoop.hbase.tool.LoadIncrementalHFiles.LoadQueueItem + +
  • org.apache.hadoop.mapreduce.Mapper<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
  • -
  • org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.BulkHFileVisitor<TFamily>
  • Enum Hierarchy