aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PlannerPhase.java
diff options
context:
space:
mode:
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/planner/PlannerPhase.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/planner/PlannerPhase.java6
1 files changed, 4 insertions, 2 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PlannerPhase.java b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PlannerPhase.java
index b6b0f58a0..5b032d061 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PlannerPhase.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/planner/PlannerPhase.java
@@ -406,7 +406,8 @@ public enum PlannerPhase {
ParquetPruneScanRule.getFilterOnScanParquet(optimizerRulesContext),
// Include LIMIT_ON_PROJECT since LIMIT_ON_SCAN may not work without it
DrillPushLimitToScanRule.LIMIT_ON_PROJECT,
- DrillPushLimitToScanRule.LIMIT_ON_SCAN
+ DrillPushLimitToScanRule.LIMIT_ON_SCAN,
+ PruneScanRule.getConvertAggScanToValuesRule(optimizerRulesContext)
)
.build();
@@ -472,7 +473,8 @@ public enum PlannerPhase {
.addAll(getItemStarRules())
.add(
PruneScanRule.getDirFilterOnProject(optimizerRulesContext),
- PruneScanRule.getDirFilterOnScan(optimizerRulesContext)
+ PruneScanRule.getDirFilterOnScan(optimizerRulesContext),
+ PruneScanRule.getConvertAggScanToValuesRule(optimizerRulesContext)
)
.build();