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

Map<Operator<?>,List<BaseWork>>	childToWorkMap
Set<ReduceSinkOperator>	clonedReduceSinks
HiveConf	conf
Set<ReduceSinkOperator>	connectedReduceSinks
Set<MapJoinOperator>	currentMapJoinOperators
Operator<? extends OperatorDesc>	currentRootOperator
TezTask	currentTask
List<UnionOperator>	currentUnionOperators
DependencyCollectionTask	dependencyTask
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
Set<WriteEntity>	outputs
Operator<? extends OperatorDesc>	parentOfRoot
ParseContext	parseContext
BaseWork	preceedingWork
List<Task<? extends Serializable>>	rootTasks
Map<Operator<?>,BaseWork>	rootToWorkMap
Map<Operator<?>,BaseWork>	unionWorkMap
Set<BaseWork>	workWithUnionOperators

Constructor Summary

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

equals, 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

currentUnionOperators

public final 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

Constructor Detail

GenTezProcContext

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