This project has retired. For details please refer to its Attic page.

org.apache.crunch.impl.mr.run
Class CrunchTaskContext

java.lang.Object
  org.apache.crunch.impl.mr.run.CrunchTaskContext

public class CrunchTaskContext
extends Object

Constructor Summary

CrunchTaskContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<Object,Object,Object,Object> taskContext, NodeContext nodeContext)

Method Summary

void	cleanup()
org.apache.hadoop.mapreduce.TaskInputOutputContext<Object,Object,Object,Object>	getContext()
CrunchMultipleOutputs<Object,Object>	getMultipleOutputs()
NodeContext	getNodeContext()
List<RTNode>	getNodes()
boolean	isDebugRun()

Methods inherited from class java.lang.Object

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

Constructor Detail

CrunchTaskContext

public CrunchTaskContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<Object,Object,Object,Object> taskContext,
                         NodeContext nodeContext)

Method Detail

getContext

public org.apache.hadoop.mapreduce.TaskInputOutputContext<Object,Object,Object,Object> getContext()

getNodeContext

public NodeContext getNodeContext()

getNodes

public List<RTNode> getNodes()
                      throws IOException

Throws:

IOException

isDebugRun

public boolean isDebugRun()

cleanup

public void cleanup()

getMultipleOutputs

public CrunchMultipleOutputs<Object,Object> getMultipleOutputs()