public abstract class AbstractJoinTaskDispatcher extends java.lang.Object implements Dispatcher
Modifier and Type | Field and Description |
---|---|
protected PhysicalContext |
physicalContext |
Constructor and Description |
---|
AbstractJoinTaskDispatcher(PhysicalContext context) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
dispatch(Node nd,
java.util.Stack<Node> stack,
java.lang.Object... nodeOutputs)
Dispatcher function.
|
long |
getTotalKnownInputSize(Context context,
MapWork currWork,
java.util.Map<java.lang.String,java.util.ArrayList<java.lang.String>> pathToAliases,
java.util.HashMap<java.lang.String,java.lang.Long> aliasToSize) |
abstract Task<? extends java.io.Serializable> |
processCurrentTask(MapRedTask currTask,
ConditionalTask conditionalTask,
Context context) |
protected void |
replaceTask(Task<? extends java.io.Serializable> currTask,
Task<? extends java.io.Serializable> newTask,
PhysicalContext physicalContext) |
protected void |
replaceTaskWithConditionalTask(Task<? extends java.io.Serializable> currTask,
ConditionalTask cndTsk,
PhysicalContext physicalContext) |
protected final PhysicalContext physicalContext
public AbstractJoinTaskDispatcher(PhysicalContext context)
public abstract Task<? extends java.io.Serializable> processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context) throws SemanticException
SemanticException
protected void replaceTaskWithConditionalTask(Task<? extends java.io.Serializable> currTask, ConditionalTask cndTsk, PhysicalContext physicalContext)
protected void replaceTask(Task<? extends java.io.Serializable> currTask, Task<? extends java.io.Serializable> newTask, PhysicalContext physicalContext)
public long getTotalKnownInputSize(Context context, MapWork currWork, java.util.Map<java.lang.String,java.util.ArrayList<java.lang.String>> pathToAliases, java.util.HashMap<java.lang.String,java.lang.Long> aliasToSize) throws SemanticException
SemanticException
public java.lang.Object dispatch(Node nd, java.util.Stack<Node> stack, java.lang.Object... nodeOutputs) throws SemanticException
Dispatcher
dispatch
in interface Dispatcher
nd
- operator to process.stack
- operator stack to process.nodeOutputs
- The argument list of outputs from processing other nodes that are
passed to this dispatcher from the walker.SemanticException
Copyright © 2012 The Apache Software Foundation