org.apache.hadoop.hive.ql.optimizer.spark

Class SplitSparkWorkResolver

java.lang.Object

org.apache.hadoop.hive.ql.optimizer.spark.SplitSparkWorkResolver

All Implemented Interfaces:

PhysicalPlanResolver

public class SplitSparkWorkResolver
extends Object
implements PhysicalPlanResolver

Do a BFS on the sparkWork graph, and look for any work that has more than one child. If we found such a work, we split it into multiple ones, one for each of its child.

Constructor Summary

Constructors

Constructor and Description
SplitSparkWorkResolver()

Method Summary

Methods

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

Constructor Detail

SplitSparkWorkResolver

public SplitSparkWorkResolver()

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