| 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  | GroupingTableMapExtract grouping columns from input record | 
| class  | IdentityTableMapPass the given key and record as-is to reduce | 
| (package private) static class  | RowCounter.RowCounterMapperMapper 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–2021 The Apache Software Foundation. All rights reserved.