public abstract class MapreduceTestingShim extends 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 String |
getMROutputDirProp() |
abstract Job |
newJob(Configuration conf) |
abstract JobContext |
newJobContext(Configuration jobConf) |
abstract JobConf |
obtainJobConf(MiniMRCluster cluster) |
abstract String |
obtainMROutputDirProp() |
public abstract JobContext newJobContext(Configuration jobConf) throws IOException
IOException
public abstract Job newJob(Configuration conf) throws IOException
IOException
public abstract JobConf obtainJobConf(MiniMRCluster cluster)
public abstract String obtainMROutputDirProp()
public static JobContext createJobContext(Configuration jobConf) throws IOException
IOException
public static JobConf getJobConf(MiniMRCluster cluster)
public static Job createJob(Configuration conf) throws IOException
IOException
public static String getMROutputDirProp()