All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
static Map<Node,Object> |
collectDynamicPruningConditions(ExprNodeDesc pred,
NodeProcessorCtx ctx) |
MapWork |
createMapWork(GenTezProcContext context,
Operator<?> root,
TezWork tezWork,
PrunedPartitionList partitions) |
static ReduceWork |
createReduceWork(GenTezProcContext context,
Operator<?> root,
TezWork tezWork) |
static UnionWork |
createUnionWork(GenTezProcContext context,
Operator<?> root,
Operator<?> leaf,
TezWork tezWork) |
static TezEdgeProperty.EdgeType |
determineEdgeType(BaseWork preceedingWork,
BaseWork followingWork,
ReduceSinkOperator reduceSinkOperator) |
static BaseWork |
getEnclosingWork(Operator<?> op,
GenTezProcContext procCtx)
getEncosingWork finds the BaseWork any given operator belongs to.
|
static void |
processAppMasterEvent(GenTezProcContext procCtx,
AppMasterEventOperator event)
processAppMasterEvent sets up the event descriptor and the MapWork.
|
static void |
processDynamicSemiJoinPushDownOperator(GenTezProcContext procCtx,
RuntimeValuesInfo runtimeValuesInfo,
ReduceSinkOperator rs) |
static void |
processFileSink(GenTezProcContext context,
FileSinkOperator fileSink) |
static Operator<?> |
removeBranch(Operator<?> event)
Remove an operator branch.
|
static void |
removeSemiJoinOperator(ParseContext context,
AppMasterEventOperator eventOp,
TableScanOperator ts) |
static void |
removeSemiJoinOperator(ParseContext context,
ReduceSinkOperator rs,
TableScanOperator ts) |
static void |
removeUnionOperators(GenTezProcContext context,
BaseWork work,
int indexForTezUnion) |
protected void |
setupMapWork(MapWork mapWork,
GenTezProcContext context,
PrunedPartitionList partitions,
TableScanOperator root,
String alias) |