| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.mapreduce | 
 Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
GroupingTableMapper
Extract grouping columns from input record. 
 | 
class  | 
IdentityTableMapper
Pass the given key and record as-is to the reduce phase. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
IdentityTableMapper.initJob(String table,
       Scan scan,
       Class<? extends TableMapper> mapper,
       org.apache.hadoop.mapreduce.Job job)
Use this before submitting a TableMap job. 
 | 
static void | 
GroupingTableMapper.initJob(String table,
       Scan scan,
       String groupColumns,
       Class<? extends TableMapper> mapper,
       org.apache.hadoop.mapreduce.Job job)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initMultiTableSnapshotMapperJob(Map<String,Collection<Scan>> snapshotScans,
                               Class<? extends TableMapper> mapper,
                               Class<?> outputKeyClass,
                               Class<?> outputValueClass,
                               org.apache.hadoop.mapreduce.Job job,
                               boolean addDependencyJars,
                               org.apache.hadoop.fs.Path tmpRestoreDir)
Sets up the job for reading from one or more table snapshots, with one or more scans
 per snapshot. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(byte[] table,
                  Scan scan,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(byte[] table,
                  Scan scan,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job,
                  boolean addDependencyJars)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(byte[] table,
                  Scan scan,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job,
                  boolean addDependencyJars,
                  Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(List<Scan> scans,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job)
Use this before submitting a Multi TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(List<Scan> scans,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job,
                  boolean addDependencyJars)
Use this before submitting a Multi TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(List<Scan> scans,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job,
                  boolean addDependencyJars,
                  boolean initCredentials)
Use this before submitting a Multi TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(String table,
                  Scan scan,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(String table,
                  Scan scan,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job,
                  boolean addDependencyJars)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(String table,
                  Scan scan,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job,
                  boolean addDependencyJars,
                  boolean initCredentials,
                  Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(String table,
                  Scan scan,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job,
                  boolean addDependencyJars,
                  Class<? extends org.apache.hadoop.mapreduce.InputFormat> inputFormatClass)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapperJob(TableName table,
                  Scan scan,
                  Class<? extends TableMapper> mapper,
                  Class<?> outputKeyClass,
                  Class<?> outputValueClass,
                  org.apache.hadoop.mapreduce.Job job)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableSnapshotMapperJob(String snapshotName,
                          Scan scan,
                          Class<? extends TableMapper> mapper,
                          Class<?> outputKeyClass,
                          Class<?> outputValueClass,
                          org.apache.hadoop.mapreduce.Job job,
                          boolean addDependencyJars,
                          org.apache.hadoop.fs.Path tmpRestoreDir)
Sets up the job for reading from a table snapshot. 
 | 
static void | 
TableMapReduceUtil.initTableSnapshotMapperJob(String snapshotName,
                          Scan scan,
                          Class<? extends TableMapper> mapper,
                          Class<?> outputKeyClass,
                          Class<?> outputValueClass,
                          org.apache.hadoop.mapreduce.Job job,
                          boolean addDependencyJars,
                          org.apache.hadoop.fs.Path tmpRestoreDir,
                          org.apache.hadoop.hbase.util.RegionSplitter.SplitAlgorithm splitAlgo,
                          int numSplitsPerRegion)
Sets up the job for reading from a table snapshot. 
 | 
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.