Interface | Description |
---|---|
BucketingSortingCtx.BucketSortCol |
BucketSortCol.
|
PhysicalPlanResolver |
Physical plan optimization interface.
|
Class | Description |
---|---|
AbstractJoinTaskDispatcher |
Common iteration methods for converting joins and sort-merge joins.
|
BucketingSortingCtx |
This class contains the bucketing sorting context that is passed
while walking the operator tree in inferring bucket/sort columns.
|
BucketingSortingCtx.BucketCol |
BucketCol.
|
BucketingSortingCtx.SortCol |
SortCol.
|
BucketingSortingInferenceOptimizer |
BucketingSortingInferenceOptimizer.
|
BucketingSortingOpProcFactory |
Operator factory for the rule processors for inferring bucketing/sorting columns.
|
BucketingSortingOpProcFactory.DefaultInferrer | |
BucketingSortingOpProcFactory.FileSinkInferrer |
Processor for FileSink operator.
|
BucketingSortingOpProcFactory.ForwardingInferrer |
Filter processor
|
BucketingSortingOpProcFactory.GroupByInferrer |
Processor for GroupBy operator.
|
BucketingSortingOpProcFactory.JoinInferrer |
Processor for Join Operator.
|
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.
|
BucketingSortingOpProcFactory.SelectInferrer |
Processor for Select operator.
|
CommonJoinResolver | |
CommonJoinTaskDispatcher |
Iterator each tasks.
|
CrossProductCheck | |
CrossProductCheck.ExtractReduceSinkInfo | |
CrossProductCheck.MapJoinCheck | |
GenMRSkewJoinProcessor |
GenMRSkewJoinProcessor.
|
GenSparkSkewJoinProcessor |
Copied from GenMRSkewJoinProcessor.
|
IndexWhereResolver | |
LocalMapJoinProcFactory |
Node processor factory for map join resolver.
|
LocalMapJoinProcFactory.LocalMapJoinProcessor |
LocalMapJoinProcessor.
|
LocalMapJoinProcFactory.MapJoinFollowedByGroupByProcessor |
MapJoinFollowByProcessor.
|
MapJoinResolver |
An implementation of PhysicalPlanResolver.
|
MapJoinResolver.LocalMapJoinProcCtx |
A container of current task and parse context.
|
MetadataOnlyOptimizer |
MetadataOnlyOptimizer determines to which TableScanOperators "metadata only"
optimization can be applied.
|
NullScanOptimizer |
This optimizer attempts following two optimizations:
1.
|
NullScanTaskDispatcher |
Iterate over all tasks one by one and removes all input paths from task if conditions as
defined in rules match.
|
PhysicalContext |
physical context used by physical resolvers.
|
PhysicalOptimizer |
A hierarchy physical optimizer, which contains a list of
PhysicalPlanResolver.
|
SamplingOptimizer |
Mark final MapredWork for ORDER BY to use sampling and set number of reduce task as -1
|
SkewJoinProcFactory |
Node processor factory for skew join resolver.
|
SkewJoinProcFactory.SkewJoinDefaultProcessor |
SkewJoinDefaultProcessor.
|
SkewJoinProcFactory.SkewJoinJoinProcessor |
SkewJoinJoinProcessor.
|
SkewJoinResolver |
An implementation of PhysicalPlanResolver.
|
SkewJoinResolver.SkewJoinProcCtx |
A container of current task and parse context.
|
SortMergeJoinResolver | |
SortMergeJoinTaskDispatcher |
Iterator over each task.
|
SparkCrossProductCheck |
Check each MapJoin and ShuffleJoin Operator to see if they are performing a cross product.
|
SparkMapJoinResolver | |
StageIDsRearranger |
Simple renumbering of stage ids
|
StageIDsRearranger.TaskTraverse | |
Vectorizer |
Copyright © 2017 The Apache Software Foundation. All rights reserved.