org.apache.hadoop.hive.ql.parse

Class GenTezProcContext

java.lang.Object

org.apache.hadoop.hive.ql.parse.GenTezProcContext

All Implemented Interfaces:

NodeProcessorCtx

public class GenTezProcContext
extends Object
implements NodeProcessorCtx

GenTezProcContext. GenTezProcContext maintains information about the tasks and operators as we walk the operator tree to break them into TezTasks.

Field Summary

Fields

Modifier and Type	Field and Description
Set<AppMasterEventOperator>	abandonedEventOperatorSet
Map<Operator<?>,List<BaseWork>>	childToWorkMap
Set<ReduceSinkOperator>	clonedReduceSinks
HiveConf	conf
Set<ReduceSinkOperator>	connectedReduceSinks
Set<MapJoinOperator>	currentMapJoinOperators
CommonMergeJoinOperator	currentMergeJoinOperator
Operator<? extends OperatorDesc>	currentRootOperator
TezTask	currentTask
List<UnionOperator>	currentUnionOperators
DependencyCollectionTask	dependencyTask
Set<AppMasterEventOperator>	eventOperatorSet
Set<FileSinkOperator>	fileSinkSet
Set<ReadEntity>	inputs
Map<Operator<?>,BaseWork>	leafOperatorToFollowingWork
Map<Operator<?>,List<Operator<?>>>	linkChildOpWithDummyOp
Map<org.apache.hadoop.fs.Path,List<FileSinkDesc>>	linkedFileSinks
Map<Operator<?>,Map<BaseWork,TezEdgeProperty>>	linkOpWithWorkMap
Map<BaseWork,List<ReduceSinkOperator>>	linkWorkWithReduceSinkMap
Map<MapJoinOperator,List<Operator<?>>>	mapJoinParentMap
Map<MapJoinOperator,List<BaseWork>>	mapJoinWorkMap
List<Task<MoveWork>>	moveTask
Map<Operator<?>,MergeJoinWork>	opMergeJoinWorkMap
Set<WriteEntity>	outputs
Operator<? extends OperatorDesc>	parentOfRoot
ParseContext	parseContext
BaseWork	preceedingWork
List<Task<? extends Serializable>>	rootTasks
Map<Operator<?>,BaseWork>	rootToWorkMap
Map<Operator<?>,UnionWork>	rootUnionWorkMap
Map<TableScanOperator,List<AppMasterEventOperator>>	tsToEventMap
Map<Operator<?>,BaseWork>	unionWorkMap
Set<BaseWork>	workWithUnionOperators

Constructor Summary

Constructors

Constructor and Description
GenTezProcContext(HiveConf conf, ParseContext parseContext, List<Task<MoveWork>> moveTask, List<Task<? extends Serializable>> rootTasks, Set<ReadEntity> inputs, Set<WriteEntity> outputs)

Method Summary

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

moveTask

public final List<Task<MoveWork>> moveTask

rootTasks

public final List<Task<? extends Serializable>> rootTasks

inputs

public final Set<ReadEntity> inputs

outputs

public final Set<WriteEntity> outputs

currentRootOperator

public Operator<? extends OperatorDesc> currentRootOperator

parentOfRoot

public Operator<? extends OperatorDesc> parentOfRoot

currentTask

public TezTask currentTask

preceedingWork

public BaseWork preceedingWork

leafOperatorToFollowingWork

public final Map<Operator<?>,BaseWork> leafOperatorToFollowingWork

linkOpWithWorkMap

public final Map<Operator<?>,Map<BaseWork,TezEdgeProperty>> linkOpWithWorkMap

linkWorkWithReduceSinkMap

public final Map<BaseWork,List<ReduceSinkOperator>> linkWorkWithReduceSinkMap

mapJoinWorkMap

public final Map<MapJoinOperator,List<BaseWork>> mapJoinWorkMap

rootToWorkMap

public final Map<Operator<?>,BaseWork> rootToWorkMap

childToWorkMap

public final Map<Operator<?>,List<BaseWork>> childToWorkMap

mapJoinParentMap

public final Map<MapJoinOperator,List<Operator<?>>> mapJoinParentMap

linkChildOpWithDummyOp

public final Map<Operator<?>,List<Operator<?>>> linkChildOpWithDummyOp

dependencyTask

public final DependencyCollectionTask dependencyTask

currentMapJoinOperators

public final Set<MapJoinOperator> currentMapJoinOperators

unionWorkMap

public final Map<Operator<?>,BaseWork> unionWorkMap

rootUnionWorkMap

public final Map<Operator<?>,UnionWork> rootUnionWorkMap

currentUnionOperators

public List<UnionOperator> currentUnionOperators

workWithUnionOperators

public final Set<BaseWork> workWithUnionOperators

clonedReduceSinks

public final Set<ReduceSinkOperator> clonedReduceSinks

linkedFileSinks

public final Map<org.apache.hadoop.fs.Path,List<FileSinkDesc>> linkedFileSinks

fileSinkSet

public final Set<FileSinkOperator> fileSinkSet

connectedReduceSinks

public final Set<ReduceSinkOperator> connectedReduceSinks

opMergeJoinWorkMap

public final Map<Operator<?>,MergeJoinWork> opMergeJoinWorkMap

currentMergeJoinOperator

public CommonMergeJoinOperator currentMergeJoinOperator

eventOperatorSet

public final Set<AppMasterEventOperator> eventOperatorSet

abandonedEventOperatorSet

public final Set<AppMasterEventOperator> abandonedEventOperatorSet

tsToEventMap

public final Map<TableScanOperator,List<AppMasterEventOperator>> tsToEventMap

Constructor Detail

GenTezProcContext

public GenTezProcContext(HiveConf conf,
                 ParseContext parseContext,
                 List<Task<MoveWork>> moveTask,
                 List<Task<? extends Serializable>> rootTasks,
                 Set<ReadEntity> inputs,
                 Set<WriteEntity> outputs)