public class CommonJoinTaskDispatcher extends AbstractJoinTaskDispatcher implements Dispatcher
physicalContext
Constructor and Description |
---|
CommonJoinTaskDispatcher(PhysicalContext context) |
Modifier and Type | Method and Description |
---|---|
static boolean |
cannotConvert(long aliasKnownSize,
long aliasTotalKnownInputSize,
long ThresholdOfSmallTblSizeSum) |
Task<? extends Serializable> |
processCurrentTask(MapRedTask currTask,
ConditionalTask conditionalTask,
Context context) |
dispatch, getTotalKnownInputSize, replaceTask, replaceTaskWithConditionalTask
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
dispatch
public CommonJoinTaskDispatcher(PhysicalContext context)
public static boolean cannotConvert(long aliasKnownSize, long aliasTotalKnownInputSize, long ThresholdOfSmallTblSizeSum)
public Task<? extends Serializable> processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context) throws SemanticException
processCurrentTask
in class AbstractJoinTaskDispatcher
SemanticException
Copyright © 2019 The Apache Software Foundation. All rights reserved.