diff --git a/core/trino-main/src/main/java/io/trino/SystemSessionProperties.java b/core/trino-main/src/main/java/io/trino/SystemSessionProperties.java index bbe14931bc05..5fc4fc5f7269 100644 --- a/core/trino-main/src/main/java/io/trino/SystemSessionProperties.java +++ b/core/trino-main/src/main/java/io/trino/SystemSessionProperties.java @@ -485,7 +485,7 @@ public SystemSessionProperties( booleanProperty( PUSH_PARTIAL_AGGREGATION_THROUGH_JOIN, "Push partial aggregations below joins", - optimizerConfig.isPushPartialAggregationThoughJoin(), + optimizerConfig.isPushPartialAggregationThroughJoin(), false), booleanProperty( PRE_AGGREGATE_CASE_AGGREGATIONS_ENABLED, diff --git a/core/trino-main/src/main/java/io/trino/sql/planner/OptimizerConfig.java b/core/trino-main/src/main/java/io/trino/sql/planner/OptimizerConfig.java index a32bcf633ca5..d718c5a9adff 100644 --- a/core/trino-main/src/main/java/io/trino/sql/planner/OptimizerConfig.java +++ b/core/trino-main/src/main/java/io/trino/sql/planner/OptimizerConfig.java @@ -70,7 +70,7 @@ public class OptimizerConfig private boolean preferPartialAggregation = true; private boolean pushAggregationThroughOuterJoin = true; private boolean enableIntermediateAggregations; - private boolean pushPartialAggregationThoughJoin; + private boolean pushPartialAggregationThroughJoin; private boolean preAggregateCaseAggregationsEnabled = true; private boolean optimizeMixedDistinctAggregations; private boolean enableForcedExchangeBelowGroupId = true; @@ -435,15 +435,15 @@ public OptimizerConfig setPushAggregationThroughOuterJoin(boolean pushAggregatio return this; } - public boolean isPushPartialAggregationThoughJoin() + public boolean isPushPartialAggregationThroughJoin() { - return pushPartialAggregationThoughJoin; + return pushPartialAggregationThroughJoin; } @Config("optimizer.push-partial-aggregation-through-join") - public OptimizerConfig setPushPartialAggregationThoughJoin(boolean pushPartialAggregationThoughJoin) + public OptimizerConfig setPushPartialAggregationThroughJoin(boolean pushPartialAggregationThroughJoin) { - this.pushPartialAggregationThoughJoin = pushPartialAggregationThoughJoin; + this.pushPartialAggregationThroughJoin = pushPartialAggregationThroughJoin; return this; } diff --git a/core/trino-main/src/test/java/io/trino/cost/TestOptimizerConfig.java b/core/trino-main/src/test/java/io/trino/cost/TestOptimizerConfig.java index 7d12469b45cd..db574345a214 100644 --- a/core/trino-main/src/test/java/io/trino/cost/TestOptimizerConfig.java +++ b/core/trino-main/src/test/java/io/trino/cost/TestOptimizerConfig.java @@ -68,7 +68,7 @@ public void testDefaults() .setEnableForcedExchangeBelowGroupId(true) .setEnableIntermediateAggregations(false) .setPushAggregationThroughOuterJoin(true) - .setPushPartialAggregationThoughJoin(false) + .setPushPartialAggregationThroughJoin(false) .setPreAggregateCaseAggregationsEnabled(true) .setMarkDistinctStrategy(null) .setPreferPartialAggregation(true) @@ -180,7 +180,7 @@ public void testExplicitPropertyMappings() .setPushTableWriteThroughUnion(false) .setDictionaryAggregation(true) .setPushAggregationThroughOuterJoin(false) - .setPushPartialAggregationThoughJoin(true) + .setPushPartialAggregationThroughJoin(true) .setPreAggregateCaseAggregationsEnabled(false) .setEnableIntermediateAggregations(true) .setMarkDistinctStrategy(ALWAYS)