org.apache.tez.mapreduce.processor
Class MRTaskReporter

java.lang.Object
  org.apache.hadoop.mapreduce.StatusReporter
      org.apache.tez.mapreduce.processor.MRTaskReporter

All Implemented Interfaces:

org.apache.hadoop.mapred.Reporter, org.apache.hadoop.util.Progressable

@InterfaceAudience.Private
@InterfaceStability.Unstable
public class MRTaskReporter
extends org.apache.hadoop.mapreduce.StatusReporter
implements org.apache.hadoop.mapred.Reporter

Field Summary

Fields inherited from interface org.apache.hadoop.mapred.Reporter

NULL

Constructor Summary

MRTaskReporter(org.apache.tez.runtime.api.TezInputContext context)

MRTaskReporter(org.apache.tez.runtime.api.TezOutputContext context)

MRTaskReporter(org.apache.tez.runtime.api.TezProcessorContext context)

Method Summary

org.apache.hadoop.mapred.Counters.Counter	getCounter(Enum<?> name)
org.apache.hadoop.mapred.Counters.Counter	getCounter(String group, String name)
org.apache.hadoop.mapred.InputSplit	getInputSplit()
float	getProgress()
void	incrCounter(Enum<?> key, long amount)
void	incrCounter(String group, String counter, long amount)
void	progress()
void	setInputSplit(org.apache.hadoop.mapred.InputSplit split)
void	setProgress(float progress)
void	setStatus(String status)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MRTaskReporter

public MRTaskReporter(org.apache.tez.runtime.api.TezProcessorContext context)

MRTaskReporter

public MRTaskReporter(org.apache.tez.runtime.api.TezOutputContext context)

MRTaskReporter

public MRTaskReporter(org.apache.tez.runtime.api.TezInputContext context)

Method Detail

setProgress

public void setProgress(float progress)

setStatus

public void setStatus(String status)

Specified by:

setStatus in interface org.apache.hadoop.mapred.Reporter

Specified by:

setStatus in class org.apache.hadoop.mapreduce.StatusReporter

getProgress

public float getProgress()

Specified by:

getProgress in interface org.apache.hadoop.mapred.Reporter

Specified by:

getProgress in class org.apache.hadoop.mapreduce.StatusReporter

progress

public void progress()

Specified by:

progress in interface org.apache.hadoop.util.Progressable

Specified by:

progress in class org.apache.hadoop.mapreduce.StatusReporter

getCounter

public org.apache.hadoop.mapred.Counters.Counter getCounter(String group,
                                                            String name)

Specified by:

getCounter in interface org.apache.hadoop.mapred.Reporter

Specified by:

getCounter in class org.apache.hadoop.mapreduce.StatusReporter

getCounter

public org.apache.hadoop.mapred.Counters.Counter getCounter(Enum<?> name)

Specified by:

getCounter in interface org.apache.hadoop.mapred.Reporter

Specified by:

getCounter in class org.apache.hadoop.mapreduce.StatusReporter

incrCounter

public void incrCounter(Enum<?> key,
                        long amount)

Specified by:

incrCounter in interface org.apache.hadoop.mapred.Reporter

incrCounter

public void incrCounter(String group,
                        String counter,
                        long amount)

Specified by:

incrCounter in interface org.apache.hadoop.mapred.Reporter

setInputSplit

public void setInputSplit(org.apache.hadoop.mapred.InputSplit split)

getInputSplit

public org.apache.hadoop.mapred.InputSplit getInputSplit()
                                                  throws UnsupportedOperationException

Specified by:

getInputSplit in interface org.apache.hadoop.mapred.Reporter

Throws:

UnsupportedOperationException