org.apache.pig.tools.pigstats

Class PigStatusReporter

java.lang.Object

org.apache.hadoop.mapreduce.StatusReporter

org.apache.pig.tools.pigstats.PigStatusReporter

All Implemented Interfaces:

org.apache.hadoop.util.Progressable

@InterfaceAudience.Public
@InterfaceStability.Evolving
public class PigStatusReporter
extends org.apache.hadoop.mapreduce.StatusReporter
implements org.apache.hadoop.util.Progressable

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.Counter	getCounter(java.lang.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(java.lang.String group, java.lang.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(java.lang.Enum<?> name, long incr)
boolean	incrCounter(java.lang.String group, java.lang.String name, long incr)
void	progress()
void	setContext(TaskContext<?> context)
void	setStatus(java.lang.String status)
static void	staticDataCleanup()

Methods inherited from class java.lang.Object

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

Method Detail

staticDataCleanup

public static void staticDataCleanup()

getInstance

public static PigStatusReporter getInstance()

Get singleton instance of the context

setContext

public void setContext(TaskContext<?> context)

getCounter

@Deprecated
public org.apache.hadoop.mapreduce.Counter getCounter(java.lang.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.

Specified by:

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

getCounter

@Deprecated
public org.apache.hadoop.mapreduce.Counter getCounter(java.lang.String group,
                                                        java.lang.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.

Specified by:

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

incrCounter

public boolean incrCounter(java.lang.Enum<?> name,
                  long incr)

incrCounter

public boolean incrCounter(java.lang.String group,
                  java.lang.String name,
                  long incr)

progress

public void progress()

Specified by:

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

Specified by:

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

setStatus

public void setStatus(java.lang.String status)

Specified by:

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

getProgress

public float getProgress()