public class GenTezUtils extends Object
Constructor and Description |
---|
GenTezUtils() |
public static UnionWork createUnionWork(GenTezProcContext context, Operator<?> root, Operator<?> leaf, TezWork tezWork)
public static ReduceWork createReduceWork(GenTezProcContext context, Operator<?> root, TezWork tezWork)
public MapWork createMapWork(GenTezProcContext context, Operator<?> root, TezWork tezWork, PrunedPartitionList partitions) throws SemanticException
SemanticException
protected void setupMapWork(MapWork mapWork, GenTezProcContext context, PrunedPartitionList partitions, TableScanOperator root, String alias) throws SemanticException
SemanticException
public static void removeUnionOperators(GenTezProcContext context, BaseWork work, int indexForTezUnion) throws SemanticException
SemanticException
public static void processFileSink(GenTezProcContext context, FileSinkOperator fileSink) throws SemanticException
SemanticException
public static void processAppMasterEvent(GenTezProcContext procCtx, AppMasterEventOperator event)
procCtx
- event
- public static BaseWork getEnclosingWork(Operator<?> op, GenTezProcContext procCtx)
public static void removeBranch(Operator<?> event)
event
- the leaf node of which branch to be removedpublic static TezEdgeProperty.EdgeType determineEdgeType(BaseWork preceedingWork, BaseWork followingWork, ReduceSinkOperator reduceSinkOperator)
public static void processDynamicMinMaxPushDownOperator(GenTezProcContext procCtx, RuntimeValuesInfo runtimeValuesInfo, ReduceSinkOperator rs) throws SemanticException
SemanticException
public static void removeSemiJoinOperator(ParseContext context, ReduceSinkOperator rs, TableScanOperator ts) throws SemanticException
SemanticException
Copyright © 2021 The Apache Software Foundation. All rights reserved.