| Class | Description |
|---|---|
| CorrelationOptimizer |
Implementation of Correlation Optimizer.
|
| CorrelationUtilities |
Utilities for both CorrelationOptimizer and ReduceSinkDeDuplication.
|
| IntraQueryCorrelation |
IntraQueryCorrelation records a sub-tree of the query plan tree which can be
evaluated in a single MR job.
|
| QueryPlanTreeTransformation |
QueryPlanTreeTransformation contains static methods used to transform
the query plan tree (operator tree) based on the correlation we have
detected by Correlation Optimizer.
|
| ReduceSinkDeDuplication |
If two reducer sink operators share the same partition/sort columns and order,
they can be merged.
|
| ReduceSinkDeDuplication.AbsctractReducerReducerProc | |
| ReduceSinkDeDuplicationUtils | |
| ReduceSinkJoinDeDuplication |
Optimization to check whether any ReduceSink operator in the plan can be
simplified so data is not shuffled/sorted if it is already shuffled/sorted.
|
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.