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

Class CombineEquivalentWorkResolver

java.lang.Object

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

All Implemented Interfaces:

PhysicalPlanResolver

public class CombineEquivalentWorkResolver
extends Object
implements PhysicalPlanResolver

CombineEquivalentWorkResolver would search inside SparkWork, find and combine equivalent works.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
CombineEquivalentWorkResolver()

Method Summary

Modifier and Type	Method and Description
static void	combineEquivalentDPPSinks(SparkPartitionPruningSinkOperator first, SparkPartitionPruningSinkOperator second)
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 transient org.slf4j.Logger LOG

Constructor Detail

CombineEquivalentWorkResolver

public CombineEquivalentWorkResolver()

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

combineEquivalentDPPSinks

public static void combineEquivalentDPPSinks(SparkPartitionPruningSinkOperator first,
                                             SparkPartitionPruningSinkOperator second)