Uses of Class
org.apache.hadoop.hbase.mapreduce.TableMapper

Packages that use org.apache.hadoop.hbase.mapreduce.TableMapper
Package
Description
Provides HBase MapReduce Input/OutputFormats, a table indexing MapReduce job, and utility methods.
 
  • Uses of org.apache.hadoop.hbase.mapreduce.TableMapper in org.apache.hadoop.hbase.mapreduce

    Subclasses of org.apache.hadoop.hbase.mapreduce.TableMapper in in org.apache.hadoop.hbase.mapreduce
    Modifier and Type
    Class
    Description
    class 
    org.apache.hadoop.hbase.mapreduce.GroupingTableMapper
    Extract grouping columns from input record.
    static class 
    org.apache.hadoop.hbase.mapreduce.HashTable.HashMapper
     
    class 
    org.apache.hadoop.hbase.mapreduce.IdentityTableMapper
    Pass the given key and record as-is to the reduce phase.
    static class 
    org.apache.hadoop.hbase.mapreduce.Import.CellImporter
    A mapper that just writes out KeyValues.
    static class 
    org.apache.hadoop.hbase.mapreduce.Import.CellSortImporter
     
    static class 
    org.apache.hadoop.hbase.mapreduce.Import.Importer
    Write table content out to files in hdfs.
    static class 
    org.apache.hadoop.hbase.mapreduce.Import.KeyValueImporter
    Deprecated.
    Use Import.CellImporter.
    static class 
    org.apache.hadoop.hbase.mapreduce.Import.KeyValueSortImporter
    Deprecated.
    Use Import.CellSortImporter.
    class 
    org.apache.hadoop.hbase.mapreduce.MultithreadedTableMapper<K2,V2>
    Multithreaded implementation for @link org.apache.hbase.mapreduce.TableMapper
    static class 
    org.apache.hadoop.hbase.mapreduce.SyncTable.SyncMapper
     
    Method parameters in org.apache.hadoop.hbase.mapreduce with type arguments of type org.apache.hadoop.hbase.mapreduce.TableMapper in in
    Modifier and Type
    Method
    Description
    static void
    GroupingTableMapper.initJob(String table, org.apache.hadoop.hbase.client.Scan scan, String groupColumns, Class<? extends org.apache.hadoop.hbase.mapreduce.TableMapper> mapper, org.apache.hadoop.mapreduce.Job job)
    Use this before submitting a TableMap job.
    static void
    IdentityTableMapper.initJob(String table, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.TableMapper> mapper, org.apache.hadoop.mapreduce.Job job)
    Use this before submitting a TableMap job.
    static void
    TableMapReduceUtil.initMultiTableSnapshotMapperJob(Map<String,Collection<org.apache.hadoop.hbase.client.Scan>> snapshotScans, Class<? extends org.apache.hadoop.hbase.mapreduce.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, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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(String table, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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<org.apache.hadoop.hbase.client.Scan> scans, Class<? extends org.apache.hadoop.hbase.mapreduce.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<org.apache.hadoop.hbase.client.Scan> scans, Class<? extends org.apache.hadoop.hbase.mapreduce.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<org.apache.hadoop.hbase.client.Scan> scans, Class<? extends org.apache.hadoop.hbase.mapreduce.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(org.apache.hadoop.hbase.TableName table, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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, org.apache.hadoop.hbase.client.Scan scan, Class<? extends org.apache.hadoop.hbase.mapreduce.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.
  • Uses of org.apache.hadoop.hbase.mapreduce.TableMapper in org.apache.hadoop.hbase.mob.mapreduce

    Subclasses of org.apache.hadoop.hbase.mapreduce.TableMapper in in org.apache.hadoop.hbase.mob.mapreduce
    Modifier and Type
    Class
    Description
    static class 
    org.apache.hadoop.hbase.mob.mapreduce.MobRefReporter.MobRefMapper