| Package | Description | 
|---|---|
| org.apache.hadoop.hbase.mapred | 
 Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
GroupingTableMap
Extract grouping columns from input record 
 | 
class  | 
IdentityTableMap
Pass the given key and record as-is to reduce 
 | 
(package private) static class  | 
RowCounter.RowCounterMapper
Mapper that runs the count. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
IdentityTableMap.initJob(String table,
       String columns,
       Class<? extends TableMap> mapper,
       org.apache.hadoop.mapred.JobConf job)
Use this before submitting a TableMap job. 
 | 
static void | 
GroupingTableMap.initJob(String table,
       String columns,
       String groupColumns,
       Class<? extends TableMap> mapper,
       org.apache.hadoop.mapred.JobConf job)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initMultiTableSnapshotMapperJob(Map<String,Collection<Scan>> snapshotScans,
                               Class<? extends TableMap> mapper,
                               Class<?> outputKeyClass,
                               Class<?> outputValueClass,
                               org.apache.hadoop.mapred.JobConf job,
                               boolean addDependencyJars,
                               org.apache.hadoop.fs.Path tmpRestoreDir)
Sets up the job for reading from one or more multiple table snapshots, with one or more scans
 per snapshot. 
 | 
static void | 
TableMapReduceUtil.initTableMapJob(String table,
               String columns,
               Class<? extends TableMap> mapper,
               Class<?> outputKeyClass,
               Class<?> outputValueClass,
               org.apache.hadoop.mapred.JobConf job)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableMapJob(String table,
               String columns,
               Class<? extends TableMap> mapper,
               Class<?> outputKeyClass,
               Class<?> outputValueClass,
               org.apache.hadoop.mapred.JobConf job,
               boolean addDependencyJars)  | 
static void | 
TableMapReduceUtil.initTableMapJob(String table,
               String columns,
               Class<? extends TableMap> mapper,
               Class<?> outputKeyClass,
               Class<?> outputValueClass,
               org.apache.hadoop.mapred.JobConf job,
               boolean addDependencyJars,
               Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormat)
Use this before submitting a TableMap job. 
 | 
static void | 
TableMapReduceUtil.initTableSnapshotMapJob(String snapshotName,
                       String columns,
                       Class<? extends TableMap> mapper,
                       Class<?> outputKeyClass,
                       Class<?> outputValueClass,
                       org.apache.hadoop.mapred.JobConf job,
                       boolean addDependencyJars,
                       org.apache.hadoop.fs.Path tmpRestoreDir)
Sets up the job for reading from a table snapshot. 
 | 
static void | 
TableMapReduceUtil.initTableSnapshotMapJob(String snapshotName,
                       String columns,
                       Class<? extends TableMap> mapper,
                       Class<?> outputKeyClass,
                       Class<?> outputValueClass,
                       org.apache.hadoop.mapred.JobConf jobConf,
                       boolean addDependencyJars,
                       org.apache.hadoop.fs.Path tmpRestoreDir,
                       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.