Skip to content

Commit

Permalink
[CALCITE-6340] RelBuilder always creates Project with Convention.NONE…
Browse files Browse the repository at this point in the history
… during aggregate_

Propagate the trait set after pruning a projection under an aggregate
in RelBuilder.
  • Loading branch information
jduo committed Apr 11, 2024
1 parent e7c1f0c commit 5de8fdc
Show file tree
Hide file tree
Showing 2 changed files with 30 additions and 1 deletion.
6 changes: 5 additions & 1 deletion core/src/main/java/org/apache/calcite/tools/RelBuilder.java
Original file line number Diff line number Diff line change
Expand Up @@ -2502,8 +2502,12 @@ private RelBuilder pruneAggregateInputFieldsAndDeduplicateAggCalls(
newProjects.add(project.getProjects().get(i));
builder.add(project.getRowType().getFieldList().get(i));
}
final Convention convention =
project.getConvention() != null ? project.getConvention()
: cluster.traitSet().getConvention();

r =
project.copy(cluster.traitSet(), project.getInput(), newProjects,
project.copy(cluster.traitSet().replace(convention), project.getInput(), newProjects,

Check failure on line 2510 in core/src/main/java/org/apache/calcite/tools/RelBuilder.java

View workflow job for this annotation

GitHub Actions / CheckerFramework (JDK 11)

[Task :core:compileJava] [argument.type.incompatible] incompatible argument for parameter trait of replace. project.copy(cluster.traitSet().replace(convention), project.getInput(), newProjects, ^ found : @initialized @nullable Convention

Check failure on line 2510 in core/src/main/java/org/apache/calcite/tools/RelBuilder.java

View workflow job for this annotation

GitHub Actions / CheckerFramework (JDK 11), oldest Guava

[Task :core:compileJava] [argument.type.incompatible] incompatible argument for parameter trait of replace. project.copy(cluster.traitSet().replace(convention), project.getInput(), newProjects, ^ found : @initialized @nullable Convention
builder.build());
} else {
groupSetAfterPruning = groupSet;
Expand Down
25 changes: 25 additions & 0 deletions core/src/test/java/org/apache/calcite/test/RelBuilderTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -547,6 +547,31 @@ private void checkSimplify(UnaryOperator<RelBuilder.Config> transform,
assertThat(root, matcher);
}

/** Test case for
* <a href="https://issues.apache.org/jira/projects/CALCITE/issues/CALCITE-6340">
* [CALCITE-6340] RelBuilder always creates Project with Convention.NONE during aggregate_.</a>.
*/
@Test void testPruneProjectInputOfAggregatePreservesTraitSet() {
final RelBuilder builder = createBuilder(config -> config.withPruneInputOfAggregate(true));

// This issue only occurs when projecting more columns than there are fields and putting
// an aggregate over that projection.
RelNode root =
builder.scan("DEPT")
.adoptConvention(EnumerableConvention.INSTANCE)
.project(builder.alias(builder.field(0), "a"),
builder.alias(builder.field(1), "b"),
builder.alias(builder.field(2), "c"),
builder.alias(builder.field(1), "d"))
.aggregate(builder.groupKey(0, 1, 2, 1),
builder.aggregateCall(SqlStdOperatorTable.SUM,
builder.field(0)))
.build();

// Verify that the project under the aggregate kept the EnumerableConvention.INSTANCE trait.
assertTrue(root.getInput(0).getTraitSet().contains(EnumerableConvention.INSTANCE));
}

@Test void testScanFilterOr() {
// Equivalent SQL:
// SELECT *
Expand Down

0 comments on commit 5de8fdc

Please sign in to comment.