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 © 2022 The Apache Software Foundation. All rights reserved.