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 |
---|---|
static List<TezOperator> |
TezOperPlan.getGrandParentsForGraceParallelism(TezOperPlan tezPlan,
TezOperator op) |
Modifier and Type | Method and Description |
---|---|
void |
TezOperator.copyFeatures(TezOperator copyFrom,
List<TezOperator.OPER_FEATURE> excludeFeatures) |
boolean |
TezOperPlan.disconnect(TezOperator from,
TezOperator to) |
static List<TezOperator> |
TezOperPlan.getGrandParentsForGraceParallelism(TezOperPlan tezPlan,
TezOperator op) |
double |
TezOperator.getParallelismFactor(TezOperator successor) |
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.TezVertexGraphPrinter.visitTezOp(TezOperator tezOper) |
void |
TezPOUserFuncVisitor.visitTezOp(TezOperator tezOp) |
void |
TezPOStreamVisitor.visitTezOp(TezOperator tezOp) |
void |
TezPOPackageAnnotator.visitTezOp(TezOperator tezOp) |
void |
TezOpPlanVisitor.visitTezOp(TezOperator tezOperator) |
static void |
TezPrinter.TezVertexGraphPrinter.writePlan(TezOperPlan plan,
TezOperator tezOper,
StringBuilder buf) |
Constructor and Description |
---|
LoRearrangeDiscoverer(PhysicalPlan predPlan,
TezOperator predTezOpVertexGrp,
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 |
---|---|
void |
UnionOptimizer.connectPredecessorsToVertexGroups(TezOperator unionOp,
TezOperator pred,
PhysicalPlan predClonedUnionPlan,
TezOperator[] storeVertexGroupOps,
TezOperator[] outputVertexGroupOps)
Connects the unionOp predecessor to the store vertex groups and the output vertex groups
and disconnects it from the unionOp.
|
void |
UnionOptimizer.connectPredecessorsToVertexGroups(TezOperator unionOp,
TezOperator pred,
PhysicalPlan predClonedUnionPlan,
TezOperator[] storeVertexGroupOps,
TezOperator[] outputVertexGroupOps)
Connects the unionOp predecessor to the store vertex groups and the output vertex groups
and disconnects it from the unionOp.
|
void |
UnionOptimizer.connectPredecessorsToVertexGroups(TezOperator unionOp,
TezOperator pred,
PhysicalPlan predClonedUnionPlan,
TezOperator[] storeVertexGroupOps,
TezOperator[] outputVertexGroupOps)
Connects the unionOp predecessor to the store vertex groups and the output vertex groups
and disconnects it from the unionOp.
|
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 boolean |
UnionOptimizer.isOptimizable(TezOperator tezOp) |
static boolean |
UnionOptimizer.isOptimizableStoreFunc(TezOperator tezOp,
List<String> supportedStoreFuncs,
List<String> unsupportedStoreFuncs) |
void |
UnionOptimizer.visitTezOp(TezOperator tezOp) |
void |
TezEstimatedParallelismClearer.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) |
Constructor and Description |
---|
TezParallelismFactorVisitor(TezOperator tezOp,
TezOperator successor) |
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 boolean |
TezCompilerUtil.isNonPackageInput(String inputKey,
TezOperator tezOp) |
static void |
TezCompilerUtil.replaceInput(TezOperator tezOp,
String oldInputKey,
String newInputKey) |
static void |
TezCompilerUtil.replaceOutput(TezOperator tezOp,
String oldOutputKey,
String newOutputKey) |
void |
TezUDFContextSeparator.serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
TezOperator tezOp) |
void |
TezUDFContextSeparator.serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
TezOperator tezOp,
POStore store) |
void |
TezUDFContextSeparator.serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
TezOperator tezOp,
UDFContextSeparator.UDFType udfType) |
void |
TezUDFContextSeparator.serializeUDFContextForEdge(org.apache.hadoop.conf.Configuration conf,
TezOperator from,
TezOperator to,
UDFContextSeparator.UDFType udfType) |
static void |
TezCompilerUtil.setCustomPartitioner(String customPartitioner,
TezOperator tezOp) |
static void |
TezCompilerUtil.simpleConnectTwoVertex(TezOperPlan tezPlan,
TezOperator op1,
TezOperator op2,
String scope,
NodeIdGenerator nig) |
void |
TezUDFContextSeparator.visitTezOp(TezOperator tezOperator) |
Constructor and Description |
---|
TezUDFContextSeparator(TezOperPlan plan,
PlanWalker<TezOperator,TezOperPlan> walker) |
Modifier and Type | Method and Description |
---|---|
void |
TezScriptState.addVertexSettingsToConf(String dagName,
TezOperator tezOp,
org.apache.hadoop.conf.Configuration conf) |
String |
TezScriptState.TezDAGScriptInfo.getAlias(TezOperator tezOp) |
String |
TezScriptState.TezDAGScriptInfo.getAliasLocation(TezOperator tezOp) |
String |
TezScriptState.TezDAGScriptInfo.getPigFeatures(TezOperator tezOp) |
Copyright © 2007-2017 The Apache Software Foundation