public class CommonJoinTaskDispatcher extends AbstractJoinTaskDispatcher implements Dispatcher
physicalContext
Constructor and Description |
---|
CommonJoinTaskDispatcher(PhysicalContext context) |
Modifier and Type | Method and Description |
---|---|
static boolean |
cannotConvert(java.lang.String bigTableAlias,
java.util.Map<java.lang.String,java.lang.Long> aliasToSize,
long aliasTotalKnownInputSize,
long ThresholdOfSmallTblSizeSum) |
Task<? extends java.io.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(java.lang.String bigTableAlias, java.util.Map<java.lang.String,java.lang.Long> aliasToSize, long aliasTotalKnownInputSize, long ThresholdOfSmallTblSizeSum)
public Task<? extends java.io.Serializable> processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context) throws SemanticException
processCurrentTask
in class AbstractJoinTaskDispatcher
SemanticException
Copyright © 2012 The Apache Software Foundation