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

Constructor Summary

CommonJoinTaskDispatcher(PhysicalContext context)

Method Summary

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

Methods inherited from class java.lang.Object

equals, 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