public class TezCompilerUtil
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
TUPLE_CLASS |
Modifier and Type | Method and Description |
---|---|
static void |
addAllPredecessors(TezOperPlan tezPlan,
TezOperator tezOp,
java.util.Set<TezOperator> predSet) |
static boolean |
bagDataTypeInCombinePlan(PhysicalPlan combinePlan) |
static void |
configureValueOnlyTupleOutput(TezEdgeDescriptor edge,
org.apache.tez.dag.api.EdgeProperty.DataMovementType dataMovementType) |
static TezEdgeDescriptor |
connect(TezOperPlan plan,
TezOperator from,
TezOperator to) |
static void |
connect(TezOperPlan plan,
TezOperator from,
TezOperator to,
TezEdgeDescriptor edge) |
static void |
connectTezOpToNewPredecessor(TezOperPlan plan,
TezOperator tezOp,
TezOperator newPredecessor,
TezEdgeDescriptor edge,
java.lang.String oldInputKey) |
static void |
connectTezOpToNewSuccesor(TezOperPlan plan,
TezOperator tezOp,
TezOperator newSuccessor,
TezEdgeDescriptor edge,
java.lang.String oldOutputKey) |
static POForEach |
getForEach(POProject project,
int rp,
java.lang.String scope,
NodeIdGenerator nig) |
static POForEach |
getForEachPlain(java.lang.String scope,
NodeIdGenerator nig) |
static POStore |
getStore(java.lang.String scope,
NodeIdGenerator nig) |
static boolean |
isNonPackageInput(java.lang.String inputKey,
TezOperator tezOp) |
static void |
replaceInput(TezOperator tezOp,
java.lang.String oldInputKey,
java.lang.String newInputKey) |
static void |
replaceOutput(TezOperator tezOp,
java.lang.String oldOutputKey,
java.lang.String newOutputKey) |
static void |
setCustomPartitioner(java.lang.String customPartitioner,
TezOperator tezOp) |
static void |
simpleConnectTwoVertex(TezOperPlan tezPlan,
TezOperator op1,
TezOperator op2,
java.lang.String scope,
NodeIdGenerator nig) |
public static void simpleConnectTwoVertex(TezOperPlan tezPlan, TezOperator op1, TezOperator op2, java.lang.String scope, NodeIdGenerator nig) throws PlanException
PlanException
public static TezEdgeDescriptor connect(TezOperPlan plan, TezOperator from, TezOperator to) throws PlanException
PlanException
public static void connect(TezOperPlan plan, TezOperator from, TezOperator to, TezEdgeDescriptor edge) throws PlanException
PlanException
public static void connectTezOpToNewPredecessor(TezOperPlan plan, TezOperator tezOp, TezOperator newPredecessor, TezEdgeDescriptor edge, java.lang.String oldInputKey) throws PlanException
PlanException
public static void replaceInput(TezOperator tezOp, java.lang.String oldInputKey, java.lang.String newInputKey) throws PlanException
PlanException
public static void connectTezOpToNewSuccesor(TezOperPlan plan, TezOperator tezOp, TezOperator newSuccessor, TezEdgeDescriptor edge, java.lang.String oldOutputKey) throws PlanException
PlanException
public static void replaceOutput(TezOperator tezOp, java.lang.String oldOutputKey, java.lang.String newOutputKey) throws PlanException
PlanException
public static boolean isNonPackageInput(java.lang.String inputKey, TezOperator tezOp) throws PlanException
PlanException
public static POForEach getForEach(POProject project, int rp, java.lang.String scope, NodeIdGenerator nig)
public static POForEach getForEachPlain(java.lang.String scope, NodeIdGenerator nig)
public static POStore getStore(java.lang.String scope, NodeIdGenerator nig)
public static void setCustomPartitioner(java.lang.String customPartitioner, TezOperator tezOp) throws java.io.IOException
java.io.IOException
public static void configureValueOnlyTupleOutput(TezEdgeDescriptor edge, org.apache.tez.dag.api.EdgeProperty.DataMovementType dataMovementType)
public static boolean bagDataTypeInCombinePlan(PhysicalPlan combinePlan) throws ExecException
ExecException
public static void addAllPredecessors(TezOperPlan tezPlan, TezOperator tezOp, java.util.Set<TezOperator> predSet)
Copyright © 2007-2025 The Apache Software Foundation