com.cloudera.crunch.impl.mr.run
Class CrunchTaskContext
java.lang.Object
com.cloudera.crunch.impl.mr.run.CrunchTaskContext
public class CrunchTaskContext
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CrunchTaskContext
public CrunchTaskContext(org.apache.hadoop.mapreduce.TaskInputOutputContext<Object,Object,Object,Object> taskContext,
NodeContext nodeContext)
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()
Copyright © 2012. All Rights Reserved.