public abstract class MapreduceTestingShim
extends java.lang.Object
Constructor and Description |
---|
MapreduceTestingShim() |
Modifier and Type | Method and Description |
---|---|
static Job |
createJob(Configuration conf) |
static JobContext |
createJobContext(Configuration jobConf) |
static JobConf |
getJobConf(MiniMRCluster cluster) |
static java.lang.String |
getMROutputDirProp() |
abstract Job |
newJob(Configuration conf) |
abstract JobContext |
newJobContext(Configuration jobConf) |
abstract JobConf |
obtainJobConf(MiniMRCluster cluster) |
abstract java.lang.String |
obtainMROutputDirProp() |
public abstract JobContext newJobContext(Configuration jobConf) throws java.io.IOException
java.io.IOException
public abstract Job newJob(Configuration conf) throws java.io.IOException
java.io.IOException
public abstract JobConf obtainJobConf(MiniMRCluster cluster)
public abstract java.lang.String obtainMROutputDirProp()
public static JobContext createJobContext(Configuration jobConf) throws java.io.IOException
java.io.IOException
public static JobConf getJobConf(MiniMRCluster cluster)
public static Job createJob(Configuration conf) throws java.io.IOException
java.io.IOException
public static java.lang.String getMROutputDirProp()