public abstract class AbstractJoinTaskDispatcher extends Object implements Dispatcher
Modifier and Type | Field and Description |
---|---|
protected PhysicalContext |
physicalContext |
Constructor and Description |
---|
AbstractJoinTaskDispatcher(PhysicalContext context) |
Modifier and Type | Method and Description |
---|---|
Object |
dispatch(Node nd,
Stack<Node> stack,
Object... nodeOutputs)
Dispatcher function.
|
long |
getTotalKnownInputSize(Context context,
MapWork currWork,
Map<org.apache.hadoop.fs.Path,ArrayList<String>> pathToAliases,
HashMap<String,Long> aliasToSize) |
abstract Task<? extends Serializable> |
processCurrentTask(MapRedTask currTask,
ConditionalTask conditionalTask,
Context context) |
protected void |
replaceTask(Task<? extends Serializable> currTask,
Task<? extends Serializable> newTask) |
protected void |
replaceTaskWithConditionalTask(Task<? extends Serializable> currTask,
ConditionalTask cndTsk) |
protected final PhysicalContext physicalContext
public AbstractJoinTaskDispatcher(PhysicalContext context)
public abstract Task<? extends Serializable> processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context) throws SemanticException
SemanticException
protected void replaceTaskWithConditionalTask(Task<? extends Serializable> currTask, ConditionalTask cndTsk)
protected void replaceTask(Task<? extends Serializable> currTask, Task<? extends Serializable> newTask)
public long getTotalKnownInputSize(Context context, MapWork currWork, Map<org.apache.hadoop.fs.Path,ArrayList<String>> pathToAliases, HashMap<String,Long> aliasToSize) throws SemanticException
SemanticException
public Object dispatch(Node nd, Stack<Node> stack, 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 © 2019 The Apache Software Foundation. All rights reserved.