@InterfaceAudience.Public @InterfaceStability.Evolving public class PigStatusReporter extends org.apache.hadoop.mapreduce.StatusReporter implements org.apache.hadoop.util.Progressable, PigWarnCounter
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.Counter |
getCounter(Enum<?> name)
Deprecated.
use
incrCounter(java.lang.Enum<?>, long) instead.
This method returns MR counter which is not compatible with Tez mode. Use
incrCounter() that is compatible with both MR and Tez mode. |
org.apache.hadoop.mapreduce.Counter |
getCounter(String group,
String name)
Deprecated.
use
incrCounter(java.lang.Enum<?>, long) instead.
This method returns MR counter which is not compatible with Tez mode. Use
incrCounter() that is compatible with both MR and Tez mode. |
static PigStatusReporter |
getInstance()
Get singleton instance of the context
|
float |
getProgress() |
boolean |
incrCounter(Enum<?> name,
long incr) |
boolean |
incrCounter(String group,
String name,
long incr) |
boolean |
incrWarnCounter(Enum<?> name,
Object incr) |
boolean |
incrWarnCounter(String group,
String name,
Object incr) |
void |
progress() |
void |
setContext(TaskContext<?> context) |
void |
setStatus(String status) |
static void |
staticDataCleanup() |
public static void staticDataCleanup()
public static PigStatusReporter getInstance()
public void setContext(TaskContext<?> context)
@Deprecated public org.apache.hadoop.mapreduce.Counter getCounter(Enum<?> name)
incrCounter(java.lang.Enum<?>, long)
instead.
This method returns MR counter which is not compatible with Tez mode. Use
incrCounter() that is compatible with both MR and Tez mode.getCounter
in class org.apache.hadoop.mapreduce.StatusReporter
@Deprecated public org.apache.hadoop.mapreduce.Counter getCounter(String group, String name)
incrCounter(java.lang.Enum<?>, long)
instead.
This method returns MR counter which is not compatible with Tez mode. Use
incrCounter() that is compatible with both MR and Tez mode.getCounter
in class org.apache.hadoop.mapreduce.StatusReporter
public boolean incrCounter(Enum<?> name, long incr)
public boolean incrWarnCounter(Enum<?> name, Object incr)
incrWarnCounter
in interface PigWarnCounter
public boolean incrWarnCounter(String group, String name, Object incr)
incrWarnCounter
in interface PigWarnCounter
public void progress()
progress
in interface org.apache.hadoop.util.Progressable
progress
in class org.apache.hadoop.mapreduce.StatusReporter
public void setStatus(String status)
setStatus
in class org.apache.hadoop.mapreduce.StatusReporter
public float getProgress()
getProgress
in class org.apache.hadoop.mapreduce.StatusReporter
Copyright © 2007-2017 The Apache Software Foundation