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) 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(AppMasterEventOperator event)
event
- the leaf node of which branch to be removedpublic static TezEdgeProperty.EdgeType determineEdgeType(BaseWork preceedingWork, BaseWork followingWork)
Copyright © 2016 The Apache Software Foundation. All rights reserved.