public class SortMergeJoinTaskDispatcher extends AbstractJoinTaskDispatcher implements SemanticDispatcher
physicalContext
Constructor and Description |
---|
SortMergeJoinTaskDispatcher(PhysicalContext context) |
Modifier and Type | Method and Description |
---|---|
Task<?> |
processCurrentTask(MapRedTask currTask,
ConditionalTask conditionalTask,
Context context) |
dispatch, getTotalKnownInputSize, replaceTask, replaceTaskWithConditionalTask
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
dispatch
public SortMergeJoinTaskDispatcher(PhysicalContext context)
public Task<?> processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context) throws SemanticException
processCurrentTask
in class AbstractJoinTaskDispatcher
SemanticException
Copyright © 2023 The Apache Software Foundation. All rights reserved.