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