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

java.lang.Object
  org.apache.hadoop.hive.ql.optimizer.physical.AbstractJoinTaskDispatcher
      org.apache.hadoop.hive.ql.optimizer.physical.SortMergeJoinTaskDispatcher

All Implemented Interfaces:

Dispatcher

public class SortMergeJoinTaskDispatcher
extends AbstractJoinTaskDispatcher
implements Dispatcher

Iterator over each task. If the task has a smb join, convert the task to a conditional task. The conditional task will first try all mapjoin possibilities, and go the the smb join if the mapjoin fails. The smb join will be a backup task for all the mapjoin tasks.

Constructor Summary

SortMergeJoinTaskDispatcher(PhysicalContext context)

Method Summary

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

SortMergeJoinTaskDispatcher

public SortMergeJoinTaskDispatcher(PhysicalContext context)

Method Detail

processCurrentTask

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

Specified by:

processCurrentTask in class AbstractJoinTaskDispatcher

Throws:

SemanticException