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

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

All Implemented Interfaces:

Dispatcher

Direct Known Subclasses:

CommonJoinTaskDispatcher, SortMergeJoinTaskDispatcher

public abstract class AbstractJoinTaskDispatcher
extends Object
implements Dispatcher

Common iteration methods for converting joins and sort-merge joins.

Constructor Summary

AbstractJoinTaskDispatcher(PhysicalContext context)

Method Summary

Object	dispatch(Node nd, Stack<Node> stack, Object... nodeOutputs) Dispatcher function.
long	getTotalKnownInputSize(Context context, MapWork currWork, Map<String,ArrayList<String>> pathToAliases, HashMap<String,Long> aliasToSize)
abstract Task<? extends Serializable>	processCurrentTask(MapRedTask currTask, ConditionalTask conditionalTask, Context context)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJoinTaskDispatcher

public AbstractJoinTaskDispatcher(PhysicalContext context)

Method Detail

processCurrentTask

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

Throws:

SemanticException

getTotalKnownInputSize

public long getTotalKnownInputSize(Context context,
                                   MapWork currWork,
                                   Map<String,ArrayList<String>> pathToAliases,
                                   HashMap<String,Long> aliasToSize)
                            throws SemanticException

Throws:

SemanticException

dispatch

public Object dispatch(Node nd,
                       Stack<Node> stack,
                       Object... nodeOutputs)
                throws SemanticException

Description copied from interface: Dispatcher

Dispatcher function.

Specified by:

dispatch in interface Dispatcher

Parameters:

nd - operator to process.

stack - operator stack to process.

nodeOutputs - The argument list of outputs from processing other nodes that are passed to this dispatcher from the walker.

Returns:

Object The return object from the processing call.

Throws:

SemanticException