public class HadoopV1Reporter extends Object implements Reporter
| Constructor and Description |
|---|
HadoopV1Reporter(HadoopTaskContext ctx,
InputSplit split)
Creates new instance.
|
| Modifier and Type | Method and Description |
|---|---|
Counters.Counter |
getCounter(Enum<?> name) |
Counters.Counter |
getCounter(String grp,
String name) |
InputSplit |
getInputSplit() |
float |
getProgress() |
void |
incrCounter(Enum<?> key,
long amount) |
void |
incrCounter(String grp,
String cntr,
long amount) |
void |
progress() |
void |
setStatus(String status) |
public HadoopV1Reporter(HadoopTaskContext ctx, InputSplit split)
ctx - Context.public Counters.Counter getCounter(Enum<?> name)
getCounter in interface Reporterpublic Counters.Counter getCounter(String grp, String name)
getCounter in interface Reporterpublic void incrCounter(Enum<?> key, long amount)
incrCounter in interface Reporterpublic void incrCounter(String grp, String cntr, long amount)
incrCounter in interface Reporterpublic InputSplit getInputSplit() throws UnsupportedOperationException
getInputSplit in interface ReporterUnsupportedOperationExceptionpublic float getProgress()
getProgress in interface Reporterpublic void progress()
progress in interface Progressable
Follow @ApacheIgnite
Ignite Fabric : ver. 2.5.1-p166 Release Date : September 3 2019