Modifier and Type | Method and Description |
---|---|
void |
TezDagBuilder.visitTezOp(TezOperator tezOp) |
Modifier and Type | Method and Description |
---|---|
TezOperator |
TezOperator.getSampleOperator() |
TezOperator |
TezOperator.getSortOperator() |
Modifier and Type | Method and Description |
---|---|
void |
TezOperator.copyFeatures(TezOperator copyFrom,
java.util.List<TezOperator.OPER_FEATURE> excludeFeatures) |
boolean |
TezOperPlan.disconnect(TezOperator from,
TezOperator to) |
void |
TezOperPlan.moveTree(TezOperator root,
TezOperPlan newPlan)
Move everything below a given operator to the new operator plan.
|
void |
TezOperPlan.remove(TezOperator op) |
void |
TezOperator.setRequestedParallelismByReference(TezOperator oper) |
void |
TezOperator.setSampleOperator(TezOperator sampleOperator) |
void |
TezOperator.setSortOperator(TezOperator sortOperator) |
void |
TezPrinter.visitTezOp(TezOperator tezOper) |
void |
TezPrinter.TezGraphPrinter.visitTezOp(TezOperator tezOper) |
void |
TezPOUserFuncVisitor.visitTezOp(TezOperator tezOp) |
void |
TezPOStreamVisitor.visitTezOp(TezOperator tezOp) |
void |
TezPOPackageAnnotator.visitTezOp(TezOperator tezOp) |
void |
TezOpPlanVisitor.visitTezOp(TezOperator tezOperator) |
Constructor and Description |
---|
TezPOPackageAnnotator.LoRearrangeDiscoverer(PhysicalPlan plan,
TezOperator pkgTezOp,
POPackage pkg) |
Constructor and Description |
---|
TezOpPlanVisitor(TezOperPlan plan,
PlanWalker<TezOperator,TezOperPlan> walker) |
Modifier and Type | Class and Description |
---|---|
class |
NativeTezOper |
Modifier and Type | Method and Description |
---|---|
static void |
MultiQueryOptimizerTez.addSubPlanPropertiesToParent(TezOperator parentOper,
TezOperator subPlanOper) |
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) |
void |
UnionOptimizer.visitTezOp(TezOperator tezOp) |
void |
SecondaryKeyOptimizerTez.visitTezOp(TezOperator to) |
void |
ParallelismSetter.visitTezOp(TezOperator tezOp) |
void |
NoopFilterRemover.visitTezOp(TezOperator tezOp) |
void |
MultiQueryOptimizerTez.visitTezOp(TezOperator tezOp) |
void |
LoaderProcessor.visitTezOp(TezOperator tezOp) |
void |
CombinerOptimizer.visitTezOp(TezOperator to) |
void |
AccumulatorOptimizer.visitTezOp(TezOperator tezOp) |
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 boolean |
TezCompilerUtil.isIntermediateReducer(TezOperator tezOper)
Returns true if there are no loads or stores in a TezOperator.
|
static void |
TezCompilerUtil.setCustomPartitioner(java.lang.String customPartitioner,
TezOperator tezOp) |
static void |
TezCompilerUtil.simpleConnectTwoVertex(TezOperPlan tezPlan,
TezOperator op1,
TezOperator op2,
java.lang.String scope,
NodeIdGenerator nig) |
Modifier and Type | Method and Description |
---|---|
void |
TezScriptState.addVertexSettingsToConf(java.lang.String dagName,
TezOperator tezOp,
org.apache.hadoop.conf.Configuration conf) |
Copyright © 2007-2012 The Apache Software Foundation