org.apache.pig.backend.hadoop.executionengine
Class TaskContext<T>

java.lang.Object
  org.apache.pig.backend.hadoop.executionengine.TaskContext<T>

Direct Known Subclasses:

FetchTaskContext, MRTaskContext

public abstract class TaskContext<T>
extends Object

Constructor Summary

TaskContext()

Method Summary

abstract T	get()
abstract org.apache.hadoop.mapreduce.Counter	getCounter(Enum<?> name)
abstract org.apache.hadoop.mapreduce.Counter	getCounter(String group, String name)
float	getProgress()
abstract boolean	incrCounter(Enum<?> name, long delta)
abstract boolean	incrCounter(String group, String name, long delta)
void	progress()
void	setStatus(String status)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskContext

public TaskContext()

Method Detail

get

public abstract T get()

getCounter

public abstract org.apache.hadoop.mapreduce.Counter getCounter(Enum<?> name)

getCounter

public abstract org.apache.hadoop.mapreduce.Counter getCounter(String group,
                                                               String name)

incrCounter

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

incrCounter

public abstract boolean incrCounter(String group,
                                    String name,
                                    long delta)

progress

public void progress()

getProgress

public float getProgress()

setStatus

public void setStatus(String status)