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.IOExceptionpublic abstract Job newJob(Configuration conf)
throws java.io.IOException
java.io.IOExceptionpublic abstract JobConf obtainJobConf(MiniMRCluster cluster)
public abstract java.lang.String obtainMROutputDirProp()
public static JobContext createJobContext(Configuration jobConf)
throws java.io.IOException
java.io.IOExceptionpublic static JobConf getJobConf(MiniMRCluster cluster)
public static Job createJob(Configuration conf)
throws java.io.IOException
java.io.IOExceptionpublic static java.lang.String getMROutputDirProp()