org.apache.hadoop.hbase.mapred
Class TableMapReduceUtil

java.lang.Object
  extended by org.apache.hadoop.hbase.mapred.TableMapReduceUtil

Deprecated.

@Deprecated
public class TableMapReduceUtil
extends Object

Utility for TableMap and TableReduce


Constructor Summary
TableMapReduceUtil()
          Deprecated.  
 
Method Summary
static void addDependencyJars(org.apache.hadoop.mapred.JobConf job)
          Deprecated.  
static void initTableMapJob(String table, String columns, Class<? extends TableMap> mapper, Class<? extends org.apache.hadoop.io.WritableComparable> outputKeyClass, Class<? extends org.apache.hadoop.io.Writable> outputValueClass, org.apache.hadoop.mapred.JobConf job)
          Deprecated. Use this before submitting a TableMap job.
static void initTableMapJob(String table, String columns, Class<? extends TableMap> mapper, Class<? extends org.apache.hadoop.io.WritableComparable> outputKeyClass, Class<? extends org.apache.hadoop.io.Writable> outputValueClass, org.apache.hadoop.mapred.JobConf job, boolean addDependencyJars)
          Deprecated. Use this before submitting a TableMap job.
static void initTableReduceJob(String table, Class<? extends TableReduce> reducer, org.apache.hadoop.mapred.JobConf job)
          Deprecated. Use this before submitting a TableReduce job.
static void initTableReduceJob(String table, Class<? extends TableReduce> reducer, org.apache.hadoop.mapred.JobConf job, Class partitioner)
          Deprecated. Use this before submitting a TableReduce job.
static void initTableReduceJob(String table, Class<? extends TableReduce> reducer, org.apache.hadoop.mapred.JobConf job, Class partitioner, boolean addDependencyJars)
          Deprecated. Use this before submitting a TableReduce job.
static void limitNumMapTasks(String table, org.apache.hadoop.mapred.JobConf job)
          Deprecated. Ensures that the given number of map tasks for the given job configuration does not exceed the number of regions for the given table.
static void limitNumReduceTasks(String table, org.apache.hadoop.mapred.JobConf job)
          Deprecated. Ensures that the given number of reduce tasks for the given job configuration does not exceed the number of regions for the given table.
static void setNumMapTasks(String table, org.apache.hadoop.mapred.JobConf job)
          Deprecated. Sets the number of map tasks for the given job configuration to the number of regions the given table has.
static void setNumReduceTasks(String table, org.apache.hadoop.mapred.JobConf job)
          Deprecated. Sets the number of reduce tasks for the given job configuration to the number of regions the given table has.
static void setScannerCaching(org.apache.hadoop.mapred.JobConf job, int batchSize)
          Deprecated. Sets the number of rows to return and cache with each scanner iteration.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TableMapReduceUtil

public TableMapReduceUtil()
Deprecated. 
Method Detail

initTableMapJob

public static void initTableMapJob(String table,
                                   String columns,
                                   Class<? extends TableMap> mapper,
                                   Class<? extends org.apache.hadoop.io.WritableComparable> outputKeyClass,
                                   Class<? extends org.apache.hadoop.io.Writable> outputValueClass,
                                   org.apache.hadoop.mapred.JobConf job)
Deprecated. 
Use this before submitting a TableMap job. It will appropriately set up the JobConf.

Parameters:
table - The table name to read from.
columns - The columns to scan.
mapper - The mapper class to use.
outputKeyClass - The class of the output key.
outputValueClass - The class of the output value.
job - The current job configuration to adjust.

initTableMapJob

public static void initTableMapJob(String table,
                                   String columns,
                                   Class<? extends TableMap> mapper,
                                   Class<? extends org.apache.hadoop.io.WritableComparable> outputKeyClass,
                                   Class<? extends org.apache.hadoop.io.Writable> outputValueClass,
                                   org.apache.hadoop.mapred.JobConf job,
                                   boolean addDependencyJars)
Deprecated. 
Use this before submitting a TableMap job. It will appropriately set up the JobConf.

Parameters:
table - The table name to read from.
columns - The columns to scan.
mapper - The mapper class to use.
outputKeyClass - The class of the output key.
outputValueClass - The class of the output value.
job - The current job configuration to adjust.
addDependencyJars - upload HBase jars and jars for any of the configured job classes via the distributed cache (tmpjars).

initTableReduceJob

public static void initTableReduceJob(String table,
                                      Class<? extends TableReduce> reducer,
                                      org.apache.hadoop.mapred.JobConf job)
                               throws IOException
Deprecated. 
Use this before submitting a TableReduce job. It will appropriately set up the JobConf.

Parameters:
table - The output table.
reducer - The reducer class to use.
job - The current job configuration to adjust.
Throws:
IOException - When determining the region count fails.

initTableReduceJob

public static void initTableReduceJob(String table,
                                      Class<? extends TableReduce> reducer,
                                      org.apache.hadoop.mapred.JobConf job,
                                      Class partitioner)
                               throws IOException
Deprecated. 
Use this before submitting a TableReduce job. It will appropriately set up the JobConf.

Parameters:
table - The output table.
reducer - The reducer class to use.
job - The current job configuration to adjust.
partitioner - Partitioner to use. Pass null to use default partitioner.
Throws:
IOException - When determining the region count fails.

initTableReduceJob

public static void initTableReduceJob(String table,
                                      Class<? extends TableReduce> reducer,
                                      org.apache.hadoop.mapred.JobConf job,
                                      Class partitioner,
                                      boolean addDependencyJars)
                               throws IOException
Deprecated. 
Use this before submitting a TableReduce job. It will appropriately set up the JobConf.

Parameters:
table - The output table.
reducer - The reducer class to use.
job - The current job configuration to adjust.
partitioner - Partitioner to use. Pass null to use default partitioner.
addDependencyJars - upload HBase jars and jars for any of the configured job classes via the distributed cache (tmpjars).
Throws:
IOException - When determining the region count fails.

limitNumReduceTasks

public static void limitNumReduceTasks(String table,
                                       org.apache.hadoop.mapred.JobConf job)
                                throws IOException
Deprecated. 
Ensures that the given number of reduce tasks for the given job configuration does not exceed the number of regions for the given table.

Parameters:
table - The table to get the region count for.
job - The current job configuration to adjust.
Throws:
IOException - When retrieving the table details fails.

limitNumMapTasks

public static void limitNumMapTasks(String table,
                                    org.apache.hadoop.mapred.JobConf job)
                             throws IOException
Deprecated. 
Ensures that the given number of map tasks for the given job configuration does not exceed the number of regions for the given table.

Parameters:
table - The table to get the region count for.
job - The current job configuration to adjust.
Throws:
IOException - When retrieving the table details fails.

setNumReduceTasks

public static void setNumReduceTasks(String table,
                                     org.apache.hadoop.mapred.JobConf job)
                              throws IOException
Deprecated. 
Sets the number of reduce tasks for the given job configuration to the number of regions the given table has.

Parameters:
table - The table to get the region count for.
job - The current job configuration to adjust.
Throws:
IOException - When retrieving the table details fails.

setNumMapTasks

public static void setNumMapTasks(String table,
                                  org.apache.hadoop.mapred.JobConf job)
                           throws IOException
Deprecated. 
Sets the number of map tasks for the given job configuration to the number of regions the given table has.

Parameters:
table - The table to get the region count for.
job - The current job configuration to adjust.
Throws:
IOException - When retrieving the table details fails.

setScannerCaching

public static void setScannerCaching(org.apache.hadoop.mapred.JobConf job,
                                     int batchSize)
Deprecated. 
Sets the number of rows to return and cache with each scanner iteration. Higher caching values will enable faster mapreduce jobs at the expense of requiring more heap to contain the cached rows.

Parameters:
job - The current job configuration to adjust.
batchSize - The number of rows to return in batch with each scanner iteration.

addDependencyJars

public static void addDependencyJars(org.apache.hadoop.mapred.JobConf job)
                              throws IOException
Deprecated. 
Throws:
IOException
See Also:
TableMapReduceUtil.addDependencyJars(Job)


Copyright © 2011 The Apache Software Foundation. All Rights Reserved.