Modifier and Type | Class and Description |
---|---|
class |
AccumuloRangeGenerator |
Modifier and Type | Class and Description |
---|---|
class |
CompositeProcessor
CompositeProcessor.
|
Constructor and Description |
---|
CompositeProcessor(NodeProcessor... nodeProcessors) |
DefaultRuleDispatcher(NodeProcessor defaultProc,
Map<Rule,NodeProcessor> rules,
NodeProcessorCtx procCtx)
Constructor.
|
Constructor and Description |
---|
DefaultRuleDispatcher(NodeProcessor defaultProc,
Map<Rule,NodeProcessor> rules,
NodeProcessorCtx procCtx)
Constructor.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractBucketJoinProc
this transformation does bucket map join optimization.
|
class |
AbstractSMBJoinProc |
class |
BucketingSortingReduceSinkOptimizer.BucketSortReduceSinkProcessor
BucketSortReduceSinkProcessor.
|
class |
BucketMapjoinProc |
static class |
ColumnPrunerProcFactory.ColumnPrunerDefaultProc
The Default Node Processor for Column Pruning.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerFilterProc
Node Processor for Column Pruning on Filter Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerGroupByProc
Node Processor for Column Pruning on Group By Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerJoinProc
The Node Processor for Column Pruning on Join Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerLateralViewForwardProc
The Node Processor for Column Pruning on Lateral View Forward Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerLateralViewJoinProc
The Node Processor for Column Pruning on Lateral View Join Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerLimitProc |
static class |
ColumnPrunerProcFactory.ColumnPrunerMapJoinProc
The Node Processor for Column Pruning on Map Join Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerPTFProc
- Pruning can only be done for Windowing.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerReduceSinkProc
The Node Processor for Column Pruning on Reduce Sink Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerScriptProc |
static class |
ColumnPrunerProcFactory.ColumnPrunerSelectProc
The Node Processor for Column Pruning on Select Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerTableScanProc
The Node Processor for Column Pruning on Table Scan Operators.
|
static class |
ColumnPrunerProcFactory.ColumnPrunerUnionProc
The Node Processor for Column Pruning on Union Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateDefaultProc
The Default Node Processor for Constant Propagation.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateFileSinkProc
The Node Processor for constant propagation for FileSink Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateFilterProc
Node Processor for Constant Propagation on Filter Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateGroupByProc
Node Processor for Constant Propagate for Group By Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateJoinProc
The Node Processor for Constant Propagation for Join Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateReduceSinkProc
The Node Processor for Constant Propagation for ReduceSink Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateSelectProc
The Node Processor for Constant Propagation for Select Operators.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateStopProc
The Node Processor for Constant Propagation for Operators which is designed to stop propagate.
|
static class |
ConstantPropagateProcFactory.ConstantPropagateTableScanProc
The Node Processor for Constant Propagation for Table Scan Operators.
|
class |
ConvertJoinMapJoin
ConvertJoinMapJoin is an optimization that replaces a common join
(aka shuffle join) with a map join (aka broadcast or fragment replicate
join when possible.
|
class |
CountDistinctRewriteProc.CountDistinctProcessor
CountDistinctProcessor.
|
class |
DynamicPartitionPruningOptimization
This optimization looks for expressions of the kind "x IN (RS[n])".
|
static class |
FixedBucketPruningOptimizer.BucketBitsetGenerator |
class |
FixedBucketPruningOptimizer.FixedBucketPartitionWalker |
class |
FixedBucketPruningOptimizer.NoopWalker |
class |
GenMRFileSink1
Processor for the rule - table scan followed by reduce sink.
|
class |
GenMROperator
Processor for the rule - no specific rule fired.
|
class |
GenMRRedSink1
Processor for the rule - table scan followed by reduce sink.
|
class |
GenMRRedSink2
Processor for the rule - reduce sink followed by reduce sink.
|
class |
GenMRRedSink3
Processor for the rule - union followed by reduce sink.
|
class |
GenMRTableScan1
Processor for the rule - table scan.
|
class |
GenMRUnion1
Processor for the rule - TableScan followed by Union.
|
class |
GroupByOptimizer.SortGroupByProcessor
SortGroupByProcessor.
|
class |
GroupByOptimizer.SortGroupBySkewProcessor
SortGroupByProcessor.
|
static class |
MapJoinProcessor.CurrentMapJoin
CurrentMapJoin.
|
static class |
MapJoinProcessor.Default
Default.
|
static class |
MapJoinProcessor.MapJoinDefault
MapJoinDefault.
|
static class |
MapJoinProcessor.MapJoinFS
MapJoinFS.
|
class |
MergeJoinProc |
static class |
PrunerExpressionOperatorFactory.ColumnExprProcessor
Processor for column expressions.
|
static class |
PrunerExpressionOperatorFactory.DefaultExprProcessor
Processor for constants and null expressions.
|
static class |
PrunerExpressionOperatorFactory.FieldExprProcessor
FieldExprProcessor.
|
static class |
PrunerExpressionOperatorFactory.GenericFuncExprProcessor
If all children are candidates and refer only to one table alias then this
expr is a candidate else it is not a candidate but its children could be
final candidates.
|
static class |
PrunerOperatorFactory.DefaultPruner
Default processor which just merges its children.
|
static class |
PrunerOperatorFactory.FilterPruner
Determines the partition pruner for the filter.
|
class |
ReduceSinkMapJoinProc |
class |
RemoveDynamicPruningBySize
If we expect the number of keys for dynamic pruning to be too large we
disable it.
|
static class |
SamplePruner.DefaultPPR
DefaultPPR default processor which does nothing.
|
static class |
SamplePruner.FilterPPR
FilterPPR filter processor.
|
class |
SetReducerParallelism
SetReducerParallelism determines how many reducers should
be run for a given reduce sink.
|
static class |
SkewJoinOptimizer.SkewJoinProc |
class |
SortedMergeBucketMapjoinProc |
class |
SortedMergeJoinProc |
class |
SparkRemoveDynamicPruning
Check if dynamic partition pruning should be disabled.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
MapJoinProcessor.getCurrentMapJoin() |
static NodeProcessor |
MapJoinProcessor.getDefault() |
static NodeProcessor |
PrunerExpressionOperatorFactory.getDefaultExprProcessor()
Instantiate default expression processor.
|
static NodeProcessor |
PrunerOperatorFactory.getDefaultProc()
Instantiate default processor.
|
static NodeProcessor |
SamplePruner.getDefaultProc() |
static NodeProcessor |
PrunerExpressionOperatorFactory.getFieldProcessor()
Instantiate field processor.
|
static NodeProcessor |
ConstantPropagateProcFactory.getFileSinkProc() |
static NodeProcessor |
SamplePruner.getFilterProc() |
static NodeProcessor |
PrunerExpressionOperatorFactory.getGenericFuncProcessor()
Instantiate generic function processor.
|
static NodeProcessor |
ConstantPropagateProcFactory.getJoinProc() |
static NodeProcessor |
MapJoinProcessor.getMapJoinDefault() |
static NodeProcessor |
MapJoinProcessor.getMapJoinFS() |
static NodeProcessor |
ConstantPropagateProcFactory.getReduceSinkProc() |
static NodeProcessor |
ConstantPropagateProcFactory.getStopProc() |
static NodeProcessor |
MapJoinFactory.getTableScanMapJoin() |
static NodeProcessor |
ConstantPropagateProcFactory.getTableScanProc() |
Modifier and Type | Method and Description |
---|---|
static Map<Node,Object> |
PrunerUtils.walkExprTree(ExprNodeDesc pred,
NodeProcessorCtx ctx,
NodeProcessor colProc,
NodeProcessor fieldProc,
NodeProcessor genFuncProc,
NodeProcessor defProc)
Walk expression tree for pruner generation.
|
static void |
PrunerUtils.walkOperatorTree(ParseContext pctx,
NodeProcessorCtx opWalkerCtx,
NodeProcessor filterProc,
NodeProcessor defaultProc)
Walk operator tree for pruner generation.
|
Modifier and Type | Class and Description |
---|---|
static class |
JoinCondTypeCheckProcFactory.JoinCondColumnExprProcessor
Processor for table columns.
|
static class |
JoinCondTypeCheckProcFactory.JoinCondDefaultExprProcessor
The default processor for typechecking.
|
Modifier and Type | Class and Description |
---|---|
static class |
ReduceSinkDeDuplication.AbsctractReducerReducerProc |
Modifier and Type | Class and Description |
---|---|
static class |
ExprProcFactory.ColumnExprProcessor
Processor for column expressions.
|
static class |
ExprProcFactory.DefaultExprProcessor
Processor for constants and null expressions.
|
static class |
ExprProcFactory.GenericExprProcessor
Processor for any function or field expression.
|
static class |
OpProcFactory.DefaultLineage
Default processor.
|
static class |
OpProcFactory.FilterLineage
Filter processor.
|
static class |
OpProcFactory.GroupByLineage
Processor for GroupBy operator.
|
static class |
OpProcFactory.JoinLineage
Processor for Join Operator.
|
static class |
OpProcFactory.LateralViewJoinLineage
Processor for Join Operator.
|
static class |
OpProcFactory.ReduceSinkLineage
ReduceSink processor.
|
static class |
OpProcFactory.SelectLineage
Processor for Select operator.
|
static class |
OpProcFactory.TableScanLineage
Processor for TableScan Operator.
|
static class |
OpProcFactory.TransformLineage
Processor for Script and UDTF Operators.
|
static class |
OpProcFactory.UnionLineage
Union processor.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
ExprProcFactory.getColumnProcessor() |
static NodeProcessor |
ExprProcFactory.getDefaultExprProcessor() |
static NodeProcessor |
OpProcFactory.getDefaultProc() |
static NodeProcessor |
ExprProcFactory.getFieldProcessor() |
static NodeProcessor |
OpProcFactory.getFilterProc() |
static NodeProcessor |
ExprProcFactory.getGenericFuncProcessor() |
static NodeProcessor |
OpProcFactory.getGroupByProc() |
static NodeProcessor |
OpProcFactory.getJoinProc() |
static NodeProcessor |
OpProcFactory.getLateralViewJoinProc() |
static NodeProcessor |
OpProcFactory.getReduceSinkProc() |
static NodeProcessor |
OpProcFactory.getSelProc() |
static NodeProcessor |
OpProcFactory.getTransformProc() |
static NodeProcessor |
OpProcFactory.getTSProc() |
static NodeProcessor |
OpProcFactory.getUnionProc() |
Modifier and Type | Class and Description |
---|---|
static class |
LBExprProcFactory.LBPRColumnExprProcessor
Processor for lbpr column expressions.
|
static class |
LBPartitionProcFactory.LBPRPartitionFilterPruner
Retrieve partitions for the filter.
|
static class |
LBProcFactory.LBPRFilterPruner
Determines the list bucketing pruner for the filter.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
LBExprProcFactory.getColumnProcessor()
Instantiate column processor.
|
static NodeProcessor |
LBProcFactory.getFilterProc() |
static NodeProcessor |
LBPartitionProcFactory.getFilterProc() |
Modifier and Type | Class and Description |
---|---|
static class |
OpTraitsRulesProcFactory.DefaultRule |
static class |
OpTraitsRulesProcFactory.GroupByRule |
static class |
OpTraitsRulesProcFactory.JoinRule |
static class |
OpTraitsRulesProcFactory.MultiParentRule |
static class |
OpTraitsRulesProcFactory.ReduceSinkRule |
static class |
OpTraitsRulesProcFactory.SelectRule |
static class |
OpTraitsRulesProcFactory.TableScanRule |
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
OpTraitsRulesProcFactory.getDefaultRule() |
static NodeProcessor |
OpTraitsRulesProcFactory.getGroupByRule() |
static NodeProcessor |
OpTraitsRulesProcFactory.getJoinRule() |
static NodeProcessor |
OpTraitsRulesProcFactory.getMultiParentRule() |
static NodeProcessor |
OpTraitsRulesProcFactory.getReduceSinkRule() |
static NodeProcessor |
OpTraitsRulesProcFactory.getSelectRule() |
static NodeProcessor |
OpTraitsRulesProcFactory.getTableScanRule() |
Modifier and Type | Class and Description |
---|---|
static class |
PcrExprProcFactory.ColumnExprProcessor
Processor for column expressions.
|
static class |
PcrExprProcFactory.DefaultExprProcessor
Processor for constants and null expressions.
|
static class |
PcrExprProcFactory.FieldExprProcessor
FieldExprProcessor.
|
static class |
PcrExprProcFactory.GenericFuncExprProcessor
Processor for Generic functions
If it is AND, OR or NOT, we replace the node to be the constant true or
false if we are sure the result from children, or cut one of the child
if we know partial results.
|
static class |
PcrOpProcFactory.DefaultPCR
Default processor which does nothing
|
static class |
PcrOpProcFactory.FilterPCR
Remove partition condition in a filter operator when possible.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
PcrExprProcFactory.getColumnProcessor() |
static NodeProcessor |
PcrExprProcFactory.getDefaultExprProcessor() |
static NodeProcessor |
PcrOpProcFactory.getDefaultProc() |
static NodeProcessor |
PcrExprProcFactory.getFieldProcessor() |
static NodeProcessor |
PcrOpProcFactory.getFilterProc() |
static NodeProcessor |
PcrExprProcFactory.getGenericFuncProcessor() |
Modifier and Type | Class and Description |
---|---|
static class |
BucketingSortingOpProcFactory.DefaultInferrer |
static class |
BucketingSortingOpProcFactory.FileSinkInferrer
Processor for FileSink operator.
|
static class |
BucketingSortingOpProcFactory.ForwardingInferrer
Filter processor
|
static class |
BucketingSortingOpProcFactory.GroupByInferrer
Processor for GroupBy operator.
|
static class |
BucketingSortingOpProcFactory.JoinInferrer
Processor for Join Operator.
|
static class |
BucketingSortingOpProcFactory.MultiGroupByInferrer
Processor for GroupByOperator, the special case where it follows a ForwardOperator
There is a multi group by optimization which puts multiple group by operators in a
reducer when they share the same keys and are part of a multi insert query.
|
static class |
BucketingSortingOpProcFactory.SelectInferrer
Processor for Select operator.
|
static class |
CrossProductHandler.ExtractReduceSinkInfo |
static class |
CrossProductHandler.MapJoinCheck |
static class |
LocalMapJoinProcFactory.LocalMapJoinProcessor
LocalMapJoinProcessor.
|
static class |
LocalMapJoinProcFactory.MapJoinFollowedByGroupByProcessor
MapJoinFollowByProcessor.
|
class |
MemoryDecider.MemoryCalculator.DefaultRule |
class |
SerializeFilter.Serializer.DefaultRule |
static class |
SkewJoinProcFactory.SkewJoinDefaultProcessor
SkewJoinDefaultProcessor.
|
static class |
SkewJoinProcFactory.SkewJoinJoinProcessor
SkewJoinJoinProcessor.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
BucketingSortingOpProcFactory.getDefaultProc() |
static NodeProcessor |
LocalMapJoinProcFactory.getDefaultProc() |
static NodeProcessor |
SkewJoinProcFactory.getDefaultProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getFileSinkProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getFilterProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getForwardProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getGroupByProc() |
static NodeProcessor |
LocalMapJoinProcFactory.getGroupByProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getJoinProc() |
static NodeProcessor |
LocalMapJoinProcFactory.getJoinProc() |
static NodeProcessor |
SkewJoinProcFactory.getJoinProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getLateralViewForwardProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getLateralViewJoinProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getLimitProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getMultiGroupByProc() |
static NodeProcessor |
BucketingSortingOpProcFactory.getSelProc() |
Constructor and Description |
---|
NullScanTaskDispatcher(PhysicalContext context,
Map<Rule,NodeProcessor> rules) |
Modifier and Type | Class and Description |
---|---|
static class |
ExprProcFactory.PPRColumnExprProcessor
Processor for ppr column expressions.
|
static class |
OpProcFactory.FilterPPR
Determines the partition pruner for the filter.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
ExprProcFactory.getColumnProcessor()
Instantiate column processor.
|
static NodeProcessor |
OpProcFactory.getFilterProc() |
Modifier and Type | Class and Description |
---|---|
class |
SetSparkReducerParallelism
SetSparkReducerParallelism determines how many reducers should
be run for a given reduce sink, clone from SetReducerParallelism.
|
class |
SparkJoinHintOptimizer
This processes joins in which user specified a hint to identify the small-table.
|
class |
SparkJoinOptimizer
Converts a join to a more optimized join for the Spark path.
|
class |
SparkMapJoinOptimizer
SparkMapJoinOptimizer cloned from ConvertJoinMapJoin is an optimization that replaces a common join
(aka shuffle join) with a map join (aka broadcast or fragment replicate
join when possible.
|
class |
SparkReduceSinkMapJoinProc |
static class |
SparkReduceSinkMapJoinProc.SparkMapJoinFollowedByGroupByProcessor |
static class |
SparkSkewJoinProcFactory.SparkSkewJoinJoinProcessor |
class |
SparkSMBJoinHintOptimizer
Converts from a bucket-mapjoin created from hints to SMB mapjoin.
|
class |
SparkSortMergeJoinOptimizer
Converts a common join operator to an SMB join if eligible.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
SparkSkewJoinProcFactory.getDefaultProc() |
static NodeProcessor |
SparkSkewJoinProcFactory.getJoinProc() |
Modifier and Type | Class and Description |
---|---|
static class |
StatsRulesProcFactory.DefaultStatsRule
Default rule is to aggregate the statistics from all its parent operators.
|
static class |
StatsRulesProcFactory.FilterStatsRule
FILTER operator does not change the average row size but it does change the number of rows
emitted.
|
static class |
StatsRulesProcFactory.GroupByStatsRule
GROUPBY operator changes the number of rows.
|
static class |
StatsRulesProcFactory.JoinStatsRule
JOIN operator can yield any of the following three cases The values of join keys are
disjoint in both relations in which case T(RXS) = 0 (we need histograms for this) Join
key is primary key on relation R and foreign key on relation S in which case every tuple in S
will have a tuple in R T(RXS) = T(S) (we need histograms for this) Both R & S relation
have same value for join-key.
|
static class |
StatsRulesProcFactory.LimitStatsRule
LIMIT operator changes the number of rows and thereby the data size.
|
static class |
StatsRulesProcFactory.ReduceSinkStatsRule
ReduceSink operator does not change any of the statistics.
|
static class |
StatsRulesProcFactory.SelectStatsRule
SELECT operator doesn't change the number of rows emitted from the parent operator.
|
static class |
StatsRulesProcFactory.TableScanStatsRule
Collect basic statistics like number of rows, data size and column level statistics from the
table.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
StatsRulesProcFactory.getDefaultRule() |
static NodeProcessor |
StatsRulesProcFactory.getFilterRule() |
static NodeProcessor |
StatsRulesProcFactory.getGroupByRule() |
static NodeProcessor |
StatsRulesProcFactory.getJoinRule() |
static NodeProcessor |
StatsRulesProcFactory.getLimitRule() |
static NodeProcessor |
StatsRulesProcFactory.getReduceSinkRule() |
static NodeProcessor |
StatsRulesProcFactory.getSelectRule() |
static NodeProcessor |
StatsRulesProcFactory.getTableScanRule() |
Modifier and Type | Class and Description |
---|---|
static class |
UnionProcFactory.MapRedUnion
MapRed subquery followed by Union.
|
static class |
UnionProcFactory.MapUnion
Map-only subquery followed by Union.
|
static class |
UnionProcFactory.NoUnion
Default processor.
|
static class |
UnionProcFactory.UnionNoProcessFile
Union followed by no processing.
|
static class |
UnionProcFactory.UnknownUnion
Union subquery followed by Union.
|
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
UnionProcFactory.getMapRedUnion() |
static NodeProcessor |
UnionProcFactory.getMapUnion() |
static NodeProcessor |
UnionProcFactory.getNoUnion() |
static NodeProcessor |
UnionProcFactory.getUnionNoProcessFile() |
static NodeProcessor |
UnionProcFactory.getUnknownUnion() |
Modifier and Type | Class and Description |
---|---|
class |
AppMasterEventProcessor
FileSinkProcessor is a simple rule to remember seen unions for later
processing.
|
class |
FileSinkProcessor
FileSinkProcessor is a simple rule to remember seen file sinks for later
processing.
|
static class |
GenTezUtils.DynamicPartitionPrunerProc |
class |
GenTezWork
GenTezWork separates the operator tree into tez tasks.
|
class |
PrintOpTreeProcessor
PrintOpTreeProcessor.
|
class |
ProcessAnalyzeTable
ProcessAnalyzeTable sets up work for the several variants of analyze table
(normal, no scan.) The plan at this point will be a single
table scan operator.
|
class |
TableAccessAnalyzer.GroupByProcessor
Processor for GroupBy operator
|
class |
TableAccessAnalyzer.JoinProcessor
Processor for Join operator.
|
static class |
TypeCheckProcFactory.BoolExprProcessor
Processor for boolean constants.
|
static class |
TypeCheckProcFactory.ColumnExprProcessor
Processor for table columns.
|
static class |
TypeCheckProcFactory.DateTimeExprProcessor
Processor for date constants.
|
static class |
TypeCheckProcFactory.DefaultExprProcessor
The default processor for typechecking.
|
static class |
TypeCheckProcFactory.IntervalExprProcessor
Processor for interval constants.
|
static class |
TypeCheckProcFactory.NullExprProcessor
Processor for processing NULL expression.
|
static class |
TypeCheckProcFactory.NumExprProcessor
Processor for processing numeric constants.
|
static class |
TypeCheckProcFactory.StrExprProcessor
Processor for processing string constants.
|
static class |
TypeCheckProcFactory.SubQueryExprProcessor
Processor for subquery expressions..
|
class |
UnionProcessor
FileSinkProcessor is a simple rule to remember seen unions for later
processing.
|
Modifier and Type | Class and Description |
---|---|
class |
GenSparkWork
GenSparkWork separates the operator tree into spark tasks.
|
class |
SparkFileSinkProcessor
FileSinkProcessor handles addition of merge, move and stats tasks for filesinks.
|
class |
SparkProcessAnalyzeTable
ProcessAnalyzeTable sets up work for the several variants of analyze table
(normal, no scan) The plan at this point will be a single
table scan operator.
|
class |
SplitOpTreeForDPP
This processor triggers on SparkPartitionPruningSinkOperator.
|
Modifier and Type | Class and Description |
---|---|
static class |
ExprWalkerProcFactory.ColumnExprProcessor
ColumnExprProcessor.
|
static class |
ExprWalkerProcFactory.DefaultExprProcessor
For constants and null expressions.
|
static class |
ExprWalkerProcFactory.FieldExprProcessor
FieldExprProcessor.
|
static class |
ExprWalkerProcFactory.GenericFuncExprProcessor
If all children are candidates and refer only to one table alias then this
expr is a candidate else it is not a candidate but its children could be
final candidates.
|
static class |
OpProcFactory.DefaultPPD
Default processor which just merges its children.
|
static class |
OpProcFactory.FilterPPD
Determines the push down predicates in its where expression and then
combines it with the push down predicates that are passed from its children.
|
static class |
OpProcFactory.JoinerPPD
Determines predicates for which alias can be pushed to it's parents.
|
static class |
OpProcFactory.JoinPPD |
static class |
OpProcFactory.LateralViewForwardPPD |
static class |
OpProcFactory.PTFPPD |
static class |
OpProcFactory.ReduceSinkPPD |
static class |
OpProcFactory.ScriptPPD
Processor for Script Operator Prevents any predicates being pushed.
|
static class |
OpProcFactory.SimpleFilterPPD |
static class |
OpProcFactory.TableScanPPD
Combines predicates of its child into a single expression and adds a filter
op as new child.
|
static class |
OpProcFactory.UDTFPPD |
Modifier and Type | Method and Description |
---|---|
static NodeProcessor |
ExprWalkerProcFactory.getColumnProcessor() |
static NodeProcessor |
ExprWalkerProcFactory.getDefaultExprProcessor() |
static NodeProcessor |
OpProcFactory.getDefaultProc() |
static NodeProcessor |
OpProcFactory.getFilterProc() |
static NodeProcessor |
OpProcFactory.getFilterSyntheticJoinPredicateProc() |
static NodeProcessor |
ExprWalkerProcFactory.getGenericFuncProcessor() |
static NodeProcessor |
OpProcFactory.getJoinProc() |
static NodeProcessor |
OpProcFactory.getLIMProc() |
static NodeProcessor |
OpProcFactory.getLVFProc() |
static NodeProcessor |
OpProcFactory.getLVJProc() |
static NodeProcessor |
OpProcFactory.getPTFProc() |
static NodeProcessor |
OpProcFactory.getRSProc() |
static NodeProcessor |
OpProcFactory.getSCRProc() |
static NodeProcessor |
OpProcFactory.getTSProc() |
static NodeProcessor |
OpProcFactory.getUDTFProc() |
Modifier and Type | Class and Description |
---|---|
class |
LineageInfo
This class prints out the lineage info.
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.