Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down Expand Up @@ -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;
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -68,7 +68,7 @@ public void testDefaults()
.setEnableForcedExchangeBelowGroupId(true)
.setEnableIntermediateAggregations(false)
.setPushAggregationThroughOuterJoin(true)
.setPushPartialAggregationThoughJoin(false)
.setPushPartialAggregationThroughJoin(false)
.setPreAggregateCaseAggregationsEnabled(true)
.setMarkDistinctStrategy(null)
.setPreferPartialAggregation(true)
Expand Down Expand Up @@ -180,7 +180,7 @@ public void testExplicitPropertyMappings()
.setPushTableWriteThroughUnion(false)
.setDictionaryAggregation(true)
.setPushAggregationThroughOuterJoin(false)
.setPushPartialAggregationThoughJoin(true)
.setPushPartialAggregationThroughJoin(true)
.setPreAggregateCaseAggregationsEnabled(false)
.setEnableIntermediateAggregations(true)
.setMarkDistinctStrategy(ALWAYS)
Expand Down