Modifier and Type | Method and Description |
---|---|
static void |
TezLauncher.processLoadAndParallelism(TezOperPlan tezPlan,
PigContext pc) |
Constructor and Description |
---|
TezDagBuilder(PigContext pc,
TezOperPlan plan,
DAG dag,
java.util.Map<java.lang.String,LocalResource> localResources) |
Modifier and Type | Method and Description |
---|---|
TezOperPlan |
TezCompiler.compile()
The front-end method that the user calls to compile the plan.
|
TezOperPlan |
TezPlanContainerNode.getTezOperPlan() |
TezOperPlan |
TezCompiler.getTezPlan() |
Modifier and Type | Method and Description |
---|---|
void |
TezPlanContainer.addPlan(TezOperPlan plan) |
void |
TezOperPlan.moveTree(TezOperator root,
TezOperPlan newPlan)
Move everything below a given operator to the new operator plan.
|
void |
TezPlanContainer.updatePlan(TezOperPlan plan,
boolean succ) |
Modifier and Type | Method and Description |
---|---|
TezPlanContainerNode |
TezPlanContainer.getNextPlan(java.util.List<TezOperPlan> processedPlans) |
Constructor and Description |
---|
TezOpPlanVisitor(TezOperPlan plan,
PlanWalker<TezOperator,TezOperPlan> walker) |
TezPlanContainerNode(OperatorKey k,
TezOperPlan tezPlan) |
TezPOPackageAnnotator(TezOperPlan plan) |
TezPOStreamVisitor(TezOperPlan plan) |
TezPOUserFuncVisitor(TezOperPlan plan) |
TezPrinter.TezGraphPrinter(TezOperPlan plan) |
TezPrinter(java.io.PrintStream ps,
TezOperPlan plan) |
Constructor and Description |
---|
TezOpPlanVisitor(TezOperPlan plan,
PlanWalker<TezOperator,TezOperPlan> walker) |
Modifier and Type | Method and Description |
---|---|
int |
TezParallelismEstimator.estimateParallelism(TezOperPlan plan,
TezOperator tezOper,
org.apache.hadoop.conf.Configuration conf) |
int |
TezOperDependencyParallelismEstimator.estimateParallelism(TezOperPlan plan,
TezOperator tezOper,
org.apache.hadoop.conf.Configuration conf) |
static void |
MultiQueryOptimizerTez.removeSplittee(TezOperPlan plan,
TezOperator splitter,
TezOperator splittee) |
Constructor and Description |
---|
AccumulatorOptimizer(TezOperPlan plan) |
CombinerOptimizer(TezOperPlan plan,
boolean doMapAgg) |
CombinerOptimizer(TezOperPlan plan,
boolean doMapAgg,
CompilationMessageCollector messageCollector) |
LoaderProcessor(TezOperPlan plan,
PigContext pigContext) |
MultiQueryOptimizerTez(TezOperPlan plan) |
NoopFilterRemover(TezOperPlan plan) |
ParallelismSetter(TezOperPlan plan,
PigContext pigContext) |
SecondaryKeyOptimizerTez(TezOperPlan plan) |
UnionOptimizer(TezOperPlan plan) |
Modifier and Type | Method and Description |
---|---|
static TezEdgeDescriptor |
TezCompilerUtil.connect(TezOperPlan plan,
TezOperator from,
TezOperator to) |
static void |
TezCompilerUtil.connect(TezOperPlan plan,
TezOperator from,
TezOperator to,
TezEdgeDescriptor edge) |
static void |
TezCompilerUtil.simpleConnectTwoVertex(TezOperPlan tezPlan,
TezOperator op1,
TezOperator op2,
java.lang.String scope,
NodeIdGenerator nig) |
Modifier and Type | Method and Description |
---|---|
void |
TezScriptState.addWorkflowAdjacenciesToConf(TezOperPlan tezPlan,
org.apache.hadoop.conf.Configuration conf) |
Copyright © 2007-2012 The Apache Software Foundation