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
|
static class |
TestTableInputFormat.ExampleVerifier |
Modifier and Type | Method and Description |
---|---|
static void |
IdentityTableMap.initJob(java.lang.String table,
java.lang.String columns,
java.lang.Class<? extends TableMap> mapper,
JobConf job)
Use this before submitting a TableMap job.
|
static void |
GroupingTableMap.initJob(java.lang.String table,
java.lang.String columns,
java.lang.String groupColumns,
java.lang.Class<? extends TableMap> mapper,
JobConf job)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapJob(java.lang.String table,
java.lang.String columns,
java.lang.Class<? extends TableMap> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
JobConf job)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapJob(java.lang.String table,
java.lang.String columns,
java.lang.Class<? extends TableMap> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
JobConf job,
boolean addDependencyJars) |
static void |
TableMapReduceUtil.initTableMapJob(java.lang.String table,
java.lang.String columns,
java.lang.Class<? extends TableMap> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
JobConf job,
boolean addDependencyJars,
java.lang.Class<? extends InputFormat> inputFormat)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableSnapshotMapJob(java.lang.String snapshotName,
java.lang.String columns,
java.lang.Class<? extends TableMap> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
JobConf job,
boolean addDependencyJars,
Path tmpRestoreDir)
Sets up the job for reading from a table snapshot.
|