org.apache.crunch.impl.mr.run
Class CrunchTaskContext
java.lang.Object
org.apache.crunch.impl.mr.run.CrunchTaskContext
public class CrunchTaskContext
- extends Object
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 The Apache Software Foundation. All Rights Reserved.