org.apache.pig.tools.pigstats
Class PigStatusReporter

java.lang.Object
  extended by org.apache.hadoop.mapreduce.StatusReporter
      extended by 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
 void destroy()
           
 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)
           
 void progress()
           
 void setContext(TaskContext<?> context)
           
 void setStatus(String status)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

getInstance

public static PigStatusReporter getInstance()
Get singleton instance of the context


destroy

public void destroy()

setContext

public void setContext(TaskContext<?> context)

getCounter

@Deprecated
public 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.

Specified by:
getCounter in class org.apache.hadoop.mapreduce.StatusReporter

getCounter

@Deprecated
public 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.

Specified by:
getCounter in class org.apache.hadoop.mapreduce.StatusReporter

incrCounter

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

incrCounter

public boolean incrCounter(String group,
                           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(String status)
Specified by:
setStatus in class org.apache.hadoop.mapreduce.StatusReporter

getProgress

public float getProgress()


Copyright © 2007-2012 The Apache Software Foundation