Package org.apache.cassandra.hadoop
Class ReporterWrapper
- java.lang.Object
-
- org.apache.hadoop.mapreduce.StatusReporter
-
- org.apache.cassandra.hadoop.ReporterWrapper
-
- All Implemented Interfaces:
org.apache.hadoop.mapred.Reporter
,org.apache.hadoop.util.Progressable
public class ReporterWrapper extends org.apache.hadoop.mapreduce.StatusReporter implements org.apache.hadoop.mapred.Reporter
A reporter that works with both mapred and mapreduce APIs.
-
-
Constructor Summary
Constructors Constructor Description ReporterWrapper(org.apache.hadoop.mapred.Reporter reporter)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.hadoop.mapred.Counters.Counter
getCounter(java.lang.Enum<?> anEnum)
org.apache.hadoop.mapred.Counters.Counter
getCounter(java.lang.String s, java.lang.String s1)
org.apache.hadoop.mapred.InputSplit
getInputSplit()
float
getProgress()
void
incrCounter(java.lang.Enum<?> anEnum, long l)
void
incrCounter(java.lang.String s, java.lang.String s1, long l)
void
progress()
void
setStatus(java.lang.String s)
-
-
-
Method Detail
-
getCounter
public org.apache.hadoop.mapred.Counters.Counter getCounter(java.lang.Enum<?> anEnum)
- Specified by:
getCounter
in interfaceorg.apache.hadoop.mapred.Reporter
- Specified by:
getCounter
in classorg.apache.hadoop.mapreduce.StatusReporter
-
getCounter
public org.apache.hadoop.mapred.Counters.Counter getCounter(java.lang.String s, java.lang.String s1)
- Specified by:
getCounter
in interfaceorg.apache.hadoop.mapred.Reporter
- Specified by:
getCounter
in classorg.apache.hadoop.mapreduce.StatusReporter
-
incrCounter
public void incrCounter(java.lang.Enum<?> anEnum, long l)
- Specified by:
incrCounter
in interfaceorg.apache.hadoop.mapred.Reporter
-
incrCounter
public void incrCounter(java.lang.String s, java.lang.String s1, long l)
- Specified by:
incrCounter
in interfaceorg.apache.hadoop.mapred.Reporter
-
getInputSplit
public org.apache.hadoop.mapred.InputSplit getInputSplit() throws java.lang.UnsupportedOperationException
- Specified by:
getInputSplit
in interfaceorg.apache.hadoop.mapred.Reporter
- Throws:
java.lang.UnsupportedOperationException
-
progress
public void progress()
- Specified by:
progress
in interfaceorg.apache.hadoop.util.Progressable
- Specified by:
progress
in classorg.apache.hadoop.mapreduce.StatusReporter
-
getProgress
public float getProgress()
-
setStatus
public void setStatus(java.lang.String s)
- Specified by:
setStatus
in interfaceorg.apache.hadoop.mapred.Reporter
- Specified by:
setStatus
in classorg.apache.hadoop.mapreduce.StatusReporter
-
-