org.apache.hadoop.hbase.mapreduce

Class MapreduceTestingShim

java.lang.Object

org.apache.hadoop.hbase.mapreduce.MapreduceTestingShim

Direct Known Subclasses:

MapreduceTestingShim.MapreduceV1Shim, MapreduceTestingShim.MapreduceV2Shim

public abstract class MapreduceTestingShim
extends Object

This class provides shims for HBase to interact with the Hadoop 1.0.x and the Hadoop 0.23.x series. NOTE: No testing done against 0.22.x, or 0.21.x.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	MapreduceTestingShim.MapreduceV1Shim
private static class	MapreduceTestingShim.MapreduceV2Shim

Field Summary

Fields

Modifier and Type	Field and Description
private static Class[]	emptyParam
private static MapreduceTestingShim	instance

Constructor Summary

Constructors

Constructor and Description
MapreduceTestingShim()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.mapreduce.Job	createJob(org.apache.hadoop.conf.Configuration conf)
static org.apache.hadoop.mapreduce.JobContext	createJobContext(org.apache.hadoop.conf.Configuration jobConf)
static org.apache.hadoop.mapred.JobConf	getJobConf(org.apache.hadoop.mapred.MiniMRCluster cluster)
static String	getMROutputDirProp()
abstract org.apache.hadoop.mapreduce.Job	newJob(org.apache.hadoop.conf.Configuration conf)
abstract org.apache.hadoop.mapreduce.JobContext	newJobContext(org.apache.hadoop.conf.Configuration jobConf)
abstract org.apache.hadoop.mapred.JobConf	obtainJobConf(org.apache.hadoop.mapred.MiniMRCluster cluster)
abstract String	obtainMROutputDirProp()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

instance

private static MapreduceTestingShim instance

emptyParam

private static Class[] emptyParam

Constructor Detail

MapreduceTestingShim

public MapreduceTestingShim()

Method Detail

newJobContext

public abstract org.apache.hadoop.mapreduce.JobContext newJobContext(org.apache.hadoop.conf.Configuration jobConf)
                                                              throws IOException

Throws:

IOException

newJob

public abstract org.apache.hadoop.mapreduce.Job newJob(org.apache.hadoop.conf.Configuration conf)
                                                throws IOException

Throws:

IOException

obtainJobConf

public abstract org.apache.hadoop.mapred.JobConf obtainJobConf(org.apache.hadoop.mapred.MiniMRCluster cluster)

obtainMROutputDirProp

public abstract String obtainMROutputDirProp()

createJobContext

public static org.apache.hadoop.mapreduce.JobContext createJobContext(org.apache.hadoop.conf.Configuration jobConf)
                                                               throws IOException

Throws:

IOException

getJobConf

public static org.apache.hadoop.mapred.JobConf getJobConf(org.apache.hadoop.mapred.MiniMRCluster cluster)

createJob

public static org.apache.hadoop.mapreduce.Job createJob(org.apache.hadoop.conf.Configuration conf)
                                                 throws IOException

Throws:

IOException

getMROutputDirProp

public static String getMROutputDirProp()