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

Class CrossProductHandler

java.lang.Object

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

All Implemented Interfaces:

Dispatcher, PhysicalPlanResolver

public class CrossProductHandler
extends Object
implements PhysicalPlanResolver, Dispatcher

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CrossProductHandler.ExtractReduceSinkInfo
static class	CrossProductHandler.MapJoinCheck

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
CrossProductHandler()

Method Summary

Modifier and Type	Method and Description
Object	dispatch(Node nd, Stack<Node> stack, Object... nodeOutputs) Dispatcher function.
PhysicalContext	resolve(PhysicalContext pctx) All physical plan resolvers have to implement this entry method.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final transient org.slf4j.Logger LOG

Constructor Detail

CrossProductHandler

public CrossProductHandler()

Method Detail

resolve

public PhysicalContext resolve(PhysicalContext pctx)
                        throws SemanticException

Description copied from interface: PhysicalPlanResolver

All physical plan resolvers have to implement this entry method.

Specified by:

resolve in interface PhysicalPlanResolver

Returns:

the physical plan

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