Skip to content

Commit

Permalink
Checkstyle/autostyle
Browse files Browse the repository at this point in the history
  • Loading branch information
jduo committed Apr 29, 2024
1 parent 81b8bd9 commit aef72e3
Showing 1 changed file with 10 additions and 6 deletions.
16 changes: 10 additions & 6 deletions core/src/test/java/org/apache/calcite/test/RelBuilderTest.java
Original file line number Diff line number Diff line change
Expand Up @@ -1476,11 +1476,13 @@ private RexNode caseCall(RelBuilder b, RexNode ref, RexNode... nodes) {
EnumerableRules.ENUMERABLE_SORT_RULE,
EnumerableRules.ENUMERABLE_TABLE_SCAN_RULE);
Program program = Programs.of(prepareRules);
node = program.run(node.getCluster().getPlanner(), node,
desiredTraits, ImmutableList.of(), ImmutableList.of());
node =
program.run(node.getCluster().getPlanner(), node, desiredTraits, ImmutableList.of(),
ImmutableList.of());

node = builder.push(node)
.aggregate(builder.groupKey(0), builder.aggregateCall(
.aggregate(
builder.groupKey(0), builder.aggregateCall(
SqlStdOperatorTable.SUM, builder.field(0)))
.build();

Expand Down Expand Up @@ -1517,13 +1519,15 @@ private RexNode caseCall(RelBuilder b, RexNode ref, RexNode... nodes) {
RuleSets.ofList(EnumerableRules.ENUMERABLE_PROJECT_RULE,
EnumerableRules.ENUMERABLE_TABLE_SCAN_RULE);
Program program = Programs.of(prepareRules);
node = program.run(node.getCluster().getPlanner(), node,
desiredTraits, ImmutableList.of(), ImmutableList.of());
node =
program.run(node.getCluster().getPlanner(), node, desiredTraits, ImmutableList.of(),
ImmutableList.of());

node = node.copy(desiredTraits.plus(RelDistributions.BROADCAST_DISTRIBUTED), node.getInputs());

node = builder.push(node)
.aggregate(builder.groupKey(0), builder.aggregateCall(
.aggregate(
builder.groupKey(0), builder.aggregateCall(
SqlStdOperatorTable.SUM, builder.field(0)))
.build();

Expand Down

0 comments on commit aef72e3

Please sign in to comment.