org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Class MRTaskContext

java.lang.Object
  extended by org.apache.pig.backend.hadoop.executionengine.TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>
      extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MRTaskContext

public class MRTaskContext
extends TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>


Constructor Summary
MRTaskContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> context)
           
 
Method Summary
 org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> get()
           
 org.apache.hadoop.mapreduce.Counter getCounter(Enum<?> name)
           
 org.apache.hadoop.mapreduce.Counter getCounter(String group, String name)
           
 boolean incrCounter(Enum<?> name, long delta)
           
 boolean incrCounter(String group, String name, long delta)
           
 void progress()
           
 void setStatus(String status)
           
 
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.TaskContext
getProgress
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MRTaskContext

public MRTaskContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> context)
Method Detail

get

public org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> get()
Specified by:
get in class TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>

getCounter

public org.apache.hadoop.mapreduce.Counter getCounter(Enum<?> name)
Specified by:
getCounter in class TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>

getCounter

public org.apache.hadoop.mapreduce.Counter getCounter(String group,
                                                      String name)
Specified by:
getCounter in class TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>

incrCounter

public boolean incrCounter(Enum<?> name,
                           long delta)
Specified by:
incrCounter in class TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>

incrCounter

public boolean incrCounter(String group,
                           String name,
                           long delta)
Specified by:
incrCounter in class TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>

progress

public void progress()
Overrides:
progress in class TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>

setStatus

public void setStatus(String status)
Overrides:
setStatus in class TaskContext<org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?>>


Copyright © 2007-2012 The Apache Software Foundation