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 TableMap in org.apache.hadoop.hbase.mapred
Modifier and TypeClassDescriptionclass
Extract grouping columns from input recordclass
Pass the given key and record as-is to reduce(package private) static class
Mapper that runs the count.Modifier and TypeMethodDescriptionstatic 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
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
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.