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)

Method Summary

Modifier and Type	Method and Description
HiveConf	getConf()
Set<ReadEntity>	getInputs()
Map<MapJoinOperator,Long>	getMjOpSizes()
Set<WriteEntity>	getOutputs()
ParseContext	getParseContext()
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)

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()

getMjOpSizes

public Map<MapJoinOperator,Long> getMjOpSizes()