Package | Description |
---|---|
org.apache.hadoop.hbase.mapreduce |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.mapreduce.replication | |
org.apache.hadoop.hbase.mob.mapreduce | |
org.apache.hadoop.hbase.test |
Modifier and Type | Class and Description |
---|---|
class |
GroupingTableMapper
Extract grouping columns from input record.
|
static class |
HashTable.HashMapper |
class |
IdentityTableMapper
Pass the given key and record as-is to the reduce phase.
|
static class |
Import.Importer
Write table content out to files in hdfs.
|
static class |
Import.KeyValueImporter
A mapper that just writes out KeyValues.
|
static class |
IntegrationTestBulkLoad.LinkedListCheckingMapper
Mapper to pass over the table.
|
class |
MultithreadedTableMapper<K2,V2>
Multithreaded implementation for @link org.apache.hbase.mapreduce.TableMapper
|
static class |
SyncTable.SyncMapper |
static class |
TestMultiTableInputFormat.ScanMapper
Pass the key and value to reducer.
|
static class |
TestMultithreadedTableMapper.ProcessContentsMapper
Pass the given key and processed record reduce
|
static class |
TestTableInputFormat.ExampleVerifier |
static class |
TestTableInputFormatScanBase.ScanMapper
Pass the key and value to reduce.
|
static class |
TestTableSnapshotInputFormat.TestTableSnapshotMapper |
Modifier and Type | Method and Description |
---|---|
static void |
IdentityTableMapper.initJob(java.lang.String table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
Job job)
Use this before submitting a TableMap job.
|
static void |
GroupingTableMapper.initJob(java.lang.String table,
Scan scan,
java.lang.String groupColumns,
java.lang.Class<? extends TableMapper> mapper,
Job job)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(byte[] table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(byte[] table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job,
boolean addDependencyJars)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(byte[] table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job,
boolean addDependencyJars,
java.lang.Class<? extends InputFormat> inputFormatClass)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(java.util.List<Scan> scans,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job)
Use this before submitting a Multi TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(java.util.List<Scan> scans,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job,
boolean addDependencyJars)
Use this before submitting a Multi TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(java.util.List<Scan> scans,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job,
boolean addDependencyJars,
boolean initCredentials)
Use this before submitting a Multi TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(java.lang.String table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(java.lang.String table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job,
boolean addDependencyJars)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(java.lang.String table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job,
boolean addDependencyJars,
boolean initCredentials,
java.lang.Class<? extends InputFormat> inputFormatClass)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(java.lang.String table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job,
boolean addDependencyJars,
java.lang.Class<? extends InputFormat> inputFormatClass)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableMapperJob(TableName table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job)
Use this before submitting a TableMap job.
|
static void |
TableMapReduceUtil.initTableSnapshotMapperJob(java.lang.String snapshotName,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job,
boolean addDependencyJars,
Path tmpRestoreDir)
Sets up the job for reading from a table snapshot.
|
Modifier and Type | Class and Description |
---|---|
static class |
VerifyReplication.Verifier
Map-only comparator for 2 tables
|
Modifier and Type | Class and Description |
---|---|
class |
SweepMapper
The mapper of a sweep job.
|
Modifier and Type | Class and Description |
---|---|
static class |
IntegrationTestLoadAndVerify.VerifyMapper |
static class |
IntegrationTestWithCellVisibilityLoadAndVerify.VerifyMapper |