Modifier and Type | Class and Description |
---|---|
class |
JobGraphBuilder |
class |
SparkPOUserFuncVisitor |
class |
UDFJarsFinder |
Modifier and Type | Class and Description |
---|---|
class |
AccumulatorOptimizer
A visitor to optimize plans that determines if a vertex plan can run in
accumulative mode.
|
class |
CombinerOptimizer
This class goes through the physical plan are replaces GlobalRearrange with ReduceBy
where there are algebraic operations.
|
class |
JoinGroupOptimizerSpark
Collapse LocalRearrange,GlobalRearrange,Package to POJoinGroupSpark to reduce unnecessary
map operations to optimize join/group.
|
class |
MultiQueryOptimizerSpark
MultiQueryOptimizer for spark
|
class |
NoopFilterRemover
For historical reasons splits will always produce filters that pass
everything through unchanged.
|
class |
ParallelismSetter |
class |
SecondaryKeyOptimizerSpark
Secondary key sort optimization for spark mode
|
Modifier and Type | Class and Description |
---|---|
class |
SparkPOPackageAnnotator
This visitor visits the SparkPlan and does the following for each
SparkOperator - visits the POPackage in the plan and finds the corresponding
POLocalRearrange(s).
|
class |
SparkPrinter
A visitor mechanism printing out the logical plan.
|
class |
XMLSparkPrinter |
Modifier and Type | Method and Description |
---|---|
void |
SparkOperator.visit(SparkOpPlanVisitor v) |
Copyright © 2007-2017 The Apache Software Foundation