| 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.