private static class MapreduceTestingShim.MapreduceV1Shim extends MapreduceTestingShim
Modifier | Constructor and Description |
---|---|
private |
MapreduceV1Shim() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.Job |
newJob(org.apache.hadoop.conf.Configuration conf) |
org.apache.hadoop.mapreduce.JobContext |
newJobContext(org.apache.hadoop.conf.Configuration jobConf) |
org.apache.hadoop.mapred.JobConf |
obtainJobConf(org.apache.hadoop.mapred.MiniMRCluster cluster) |
String |
obtainMROutputDirProp() |
createJob, createJobContext, getJobConf, getMROutputDirProp
private MapreduceV1Shim()
public org.apache.hadoop.mapreduce.JobContext newJobContext(org.apache.hadoop.conf.Configuration jobConf) throws IOException
newJobContext
in class MapreduceTestingShim
IOException
public org.apache.hadoop.mapreduce.Job newJob(org.apache.hadoop.conf.Configuration conf) throws IOException
newJob
in class MapreduceTestingShim
IOException
public org.apache.hadoop.mapred.JobConf obtainJobConf(org.apache.hadoop.mapred.MiniMRCluster cluster)
obtainJobConf
in class MapreduceTestingShim
public String obtainMROutputDirProp()
obtainMROutputDirProp
in class MapreduceTestingShim
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.