Modifier and Type | Method and Description |
---|---|
static void |
TezLauncher.processLoadAndParallelism(TezOperPlan tezPlan,
PigContext pc) |
Constructor and Description |
---|
TezDagBuilder(PigContext pc,
TezOperPlan plan,
org.apache.tez.dag.api.DAG dag,
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResources) |
TezJob(org.apache.tez.dag.api.TezConfiguration conf,
org.apache.tez.dag.api.DAG dag,
Map<String,org.apache.hadoop.yarn.api.records.LocalResource> requestAMResources,
TezOperPlan tezPlan) |
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) |
static List<TezOperator> |
TezOperPlan.getGrandParentsForGraceParallelism(TezOperPlan tezPlan,
TezOperator op) |
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) |
static void |
TezPrinter.TezVertexGraphPrinter.writePlan(TezOperPlan plan,
TezOperator tezOper,
StringBuilder buf) |
Modifier and Type | Method and Description |
---|---|
TezPlanContainerNode |
TezPlanContainer.getNextPlan(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.TezVertexGraphPrinter(TezOperPlan plan) |
TezPrinter(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) |
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,
boolean unionOptimizerOn,
List<String> unionSupportedStoreFuncs,
List<String> unionUnsupportedStoreFuncs) |
NoopFilterRemover(TezOperPlan plan) |
ParallelismSetter(TezOperPlan plan,
PigContext pigContext) |
SecondaryKeyOptimizerTez(TezOperPlan plan) |
TezEstimatedParallelismClearer(TezOperPlan plan) |
UnionOptimizer(TezOperPlan plan,
List<String> supportedStoreFuncs,
List<String> unsupportedStoreFuncs) |
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.connectTezOpToNewPredecessor(TezOperPlan plan,
TezOperator tezOp,
TezOperator newPredecessor,
TezEdgeDescriptor edge,
String oldInputKey) |
static void |
TezCompilerUtil.connectTezOpToNewSuccesor(TezOperPlan plan,
TezOperator tezOp,
TezOperator newSuccessor,
TezEdgeDescriptor edge,
String oldOutputKey) |
static void |
TezCompilerUtil.simpleConnectTwoVertex(TezOperPlan tezPlan,
TezOperator op1,
TezOperator op2,
String scope,
NodeIdGenerator nig) |
Constructor and Description |
---|
TezUDFContextSeparator(TezOperPlan plan,
PlanWalker<TezOperator,TezOperPlan> walker) |
Constructor and Description |
---|
TezUDFContextSeparator(TezOperPlan plan,
PlanWalker<TezOperator,TezOperPlan> walker) |
Modifier and Type | Method and Description |
---|---|
void |
TezScriptState.addWorkflowAdjacenciesToConf(TezOperPlan tezPlan,
org.apache.hadoop.conf.Configuration conf) |
Constructor and Description |
---|
TezScriptState.TezDAGScriptInfo(TezOperPlan tezPlan) |
Copyright © 2007-2012 The Apache Software Foundation