org.apache.hadoop.hive.ql.parse

Class OptimizeTezProcContext

java.lang.Object

org.apache.hadoop.hive.ql.parse.OptimizeTezProcContext

All Implemented Interfaces:

NodeProcessorCtx

public class OptimizeTezProcContext
extends Object
implements NodeProcessorCtx

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

Field Summary

Fields

Modifier and Type	Field and Description
HiveConf	conf
com.google.common.collect.Multimap<AppMasterEventOperator,TableScanOperator>	eventOpToTableScanMap
Set<ReadEntity>	inputs
Set<WriteEntity>	outputs
ParseContext	parseContext
HashSet<AppMasterEventOperator>	pruningOpsRemovedByPriorOpt
Deque<Operator<? extends OperatorDesc>>	rootOperators
Set<ReduceSinkOperator>	visitedReduceSinks

Constructor Summary

Constructors

Constructor and Description
OptimizeTezProcContext(HiveConf conf, ParseContext parseContext, Set<ReadEntity> inputs, Set<WriteEntity> outputs)

Method Summary

Methods

Modifier and Type	Method and Description
void	setRootOperators(Deque<Operator<? extends OperatorDesc>> roots)

Methods inherited from class java.lang.Object

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

Field Detail

parseContext

public final ParseContext parseContext

conf

public final HiveConf conf

inputs

public final Set<ReadEntity> inputs

outputs

public final Set<WriteEntity> outputs

pruningOpsRemovedByPriorOpt

public HashSet<AppMasterEventOperator> pruningOpsRemovedByPriorOpt

visitedReduceSinks

public final Set<ReduceSinkOperator> visitedReduceSinks

eventOpToTableScanMap

public final com.google.common.collect.Multimap<AppMasterEventOperator,TableScanOperator> eventOpToTableScanMap

rootOperators

public Deque<Operator<? extends OperatorDesc>> rootOperators

Constructor Detail

OptimizeTezProcContext

public OptimizeTezProcContext(HiveConf conf,
                      ParseContext parseContext,
                      Set<ReadEntity> inputs,
                      Set<WriteEntity> outputs)

Method Detail

setRootOperators

public void setRootOperators(Deque<Operator<? extends OperatorDesc>> roots)