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

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

All Implemented Interfaces:

PhysicalPlanResolver

public class SkewJoinResolver
extends Object
implements PhysicalPlanResolver

An implementation of PhysicalPlanResolver. It iterator each task with a rule dispatcher for its reducer operator tree, for task with join op in reducer, it will try to add a conditional task associated a list of skew join tasks.

Nested Class Summary

static class

SkewJoinResolver.SkewJoinProcCtx A container of current task and parse context.

Constructor Summary

SkewJoinResolver()

Method Summary

PhysicalContext

resolve(PhysicalContext pctx) All physical plan resolvers have to implement this entry method.

Methods inherited from class java.lang.Object

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

Constructor Detail

SkewJoinResolver

public SkewJoinResolver()

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