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.

Field Summary

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

physicalContext

Constructor Summary

Constructors

Constructor and Description
SortMergeJoinTaskDispatcher(PhysicalContext context)

Method Summary

Methods

Modifier and Type	Method and Description
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

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