org.apache.hadoop.hive.ql.optimizer.physical

Class CommonJoinTaskDispatcher

java.lang.Object

org.apache.hadoop.hive.ql.optimizer.physical.AbstractJoinTaskDispatcher

org.apache.hadoop.hive.ql.optimizer.physical.CommonJoinTaskDispatcher

All Implemented Interfaces:

Dispatcher

public class CommonJoinTaskDispatcher
extends AbstractJoinTaskDispatcher
implements Dispatcher

Iterator each tasks. If this task has a local work,create a new task for this local work, named MapredLocalTask. then make this new generated task depends on current task's parent task, and make current task depends on this new generated task

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.optimizer.physical.AbstractJoinTaskDispatcher

physicalContext

Constructor Summary

Constructors

Constructor and Description
CommonJoinTaskDispatcher(PhysicalContext context)

Method Summary

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)

Methods inherited from class org.apache.hadoop.hive.ql.optimizer.physical.AbstractJoinTaskDispatcher

dispatch, getTotalKnownInputSize, replaceTask, replaceTaskWithConditionalTask

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hive.ql.lib.Dispatcher

dispatch

Constructor Detail

CommonJoinTaskDispatcher

public CommonJoinTaskDispatcher(PhysicalContext context)

Method Detail

cannotConvert

public static boolean cannotConvert(long aliasKnownSize,
                                    long aliasTotalKnownInputSize,
                                    long ThresholdOfSmallTblSizeSum)

processCurrentTask

public Task<? extends Serializable> processCurrentTask(MapRedTask currTask,
                                                       ConditionalTask conditionalTask,
                                                       Context context)
                                                throws SemanticException

Specified by:

processCurrentTask in class AbstractJoinTaskDispatcher

Throws:

SemanticException