butlermh

@Override
public void map(InputKey key, InputValue value,
   OutputCollector<OutputKey, OutputValue> output, Reporter reporter)
   throws IOException {
BECOMES
@Override	
public void map(InputKey key, InputValue value,
    Mapper<InputKey, InputValue, OutputKey, OutputValue>.Context context)
    throws IOException, InterruptedException {     

butlermh

reporter.incrCounter(family, type, 1);
BECOMES
context.getCounter(family, type).increment(1);

output.collect(key, value);
BECOMES
context.write(key, value);

butlermh

@Override
public void close() throws IOException {
BECOMES
@Override
public void cleanup(Context context) throws IOException, InterruptedException {

butlermh

@Overide
public void configure(JobConf job) {
  super.configure(job);
  config = job;
BECOMES
@Override
public void setup(Mapper<InputKey, InputValue, OutputKey, OutputValue>.Context context) 
  throws InterruptedException, IOException {
  super.setup(context);
  config = context.getConfiguration();

butlermh

String application_value = job.get("app.value");
BECOMES
String application_value = config.get("app.value");

Path[] localArchives = DistributedCache.getLocalCacheArchives(job);
BECOMES
Path[] localArchives = DistributedCache.getLocalCacheArchives(config);

Class handlerClass = job.getClass(handlerName, SomeProcessor.class);
BECOMES

butlermh

JobConf job = new JobConf(getConf());
BECOMES
Job job = new Job(getConf());

butlermh

job.setInputFormat(SequenceFileInputFormat.class);
job.setOutputFormat(SequenceFileOutputFormat.class);
BECOMES
job.setInputFormatClass(SequenceFileInputFormat.class);
job.setOutputFormatClass(SequenceFileOutputFormat.class);

butlermh

DistributedCache.addCacheArchive(new URI(path), job);
BECOMES
DistributedCache.addCacheArchive(new URI(path), job.getConfiguration());

job.set("some_property", property_value);
BECOMES
job.getConfiguration().set("some_property", property_value);

butlermh

JobClient.runJob(job);
BECOMES
job.waitForCompletion(true);

butlermh

dependsOn(':test-testng')

apply plugin: 'java'
apply plugin: 'maven'
apply plugin: 'eclipse'