org.apache.hadoop.hive.ql.parse.spark

Class OptimizeSparkProcContext

java.lang.Object

org.apache.hadoop.hive.ql.parse.spark.OptimizeSparkProcContext

All Implemented Interfaces:

NodeProcessorCtx

public class OptimizeSparkProcContext
extends Object
implements NodeProcessorCtx

OptimizeSparkProcContext. OptimizeSparkProcContext maintains information about the current operator plan as we walk the operator tree to do some additional optimizations on it. clone from OptimizeTezProcContext.

Constructor Summary

Constructors

Constructor and Description
OptimizeSparkProcContext(HiveConf conf, ParseContext parseContext, Set<ReadEntity> inputs, Set<WriteEntity> outputs, Deque<Operator<? extends OperatorDesc>> rootOperators)

Method Summary

Methods

Modifier and Type	Method and Description
HiveConf	getConf()
Set<ReadEntity>	getInputs()
Map<MapJoinOperator,Long>	getMjOpSizes()
Set<WriteEntity>	getOutputs()
ParseContext	getParseContext()
Deque<Operator<? extends OperatorDesc>>	getRootOperators()
Set<ReduceSinkOperator>	getVisitedReduceSinks()

Methods inherited from class java.lang.Object

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

Constructor Detail

OptimizeSparkProcContext

public OptimizeSparkProcContext(HiveConf conf,
                        ParseContext parseContext,
                        Set<ReadEntity> inputs,
                        Set<WriteEntity> outputs,
                        Deque<Operator<? extends OperatorDesc>> rootOperators)

Method Detail

getParseContext

public ParseContext getParseContext()

getConf

public HiveConf getConf()

getInputs

public Set<ReadEntity> getInputs()

getOutputs

public Set<WriteEntity> getOutputs()

getVisitedReduceSinks

public Set<ReduceSinkOperator> getVisitedReduceSinks()

getRootOperators

public Deque<Operator<? extends OperatorDesc>> getRootOperators()

getMjOpSizes

public Map<MapJoinOperator,Long> getMjOpSizes()