Uses of Interface
org.apache.hadoop.hbase.mapred.TableMap
Package
Description
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
-
Uses of org.apache.hadoop.hbase.mapred.TableMap in org.apache.hadoop.hbase.mapred
Modifier and TypeClassDescriptionclass
org.apache.hadoop.hbase.mapred.GroupingTableMap
Extract grouping columns from input recordclass
org.apache.hadoop.hbase.mapred.IdentityTableMap
Pass the given key and record as-is to reduceModifier and TypeMethodDescriptionstatic void
GroupingTableMap.initJob
(String table, String columns, String groupColumns, Class<? extends org.apache.hadoop.hbase.mapred.TableMap> mapper, org.apache.hadoop.mapred.JobConf job) Use this before submitting a TableMap job.static void
IdentityTableMap.initJob
(String table, String columns, Class<? extends org.apache.hadoop.hbase.mapred.TableMap> mapper, org.apache.hadoop.mapred.JobConf 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.mapred.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 org.apache.hadoop.hbase.mapred.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 org.apache.hadoop.hbase.mapred.TableMap> mapper, Class<?> outputKeyClass, Class<?> outputValueClass, org.apache.hadoop.mapred.JobConf job, boolean addDependencyJars) static void
TableMapReduceUtil.initTableMapJob
(String table, String columns, Class<? extends org.apache.hadoop.hbase.mapred.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 org.apache.hadoop.hbase.mapred.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 org.apache.hadoop.hbase.mapred.TableMap> mapper, Class<?> outputKeyClass, Class<?> outputValueClass, org.apache.hadoop.mapred.JobConf jobConf, 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.