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, TezTaskContext

public abstract class TaskContext<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
TaskContext()

Method Summary

Modifier and Type	Method and Description
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)