@@ -109,16 +109,16 @@ private IgniteLogicalWindowRewriteRule(Config config) {
109109 aggCalls .add (toAggregateCall (winAggCall , typeFactory ));
110110 }
111111
112- ImmutableBitSet groupSet = grp .keys ;
112+ ImmutableBitSet grpSet = grp .keys ;
113113
114114 RelNode agg = LogicalAggregate .create (
115115 input ,
116- groupSet ,
116+ grpSet ,
117117 null ,
118118 aggCalls
119119 );
120120
121- RexNode condition = buildPartitionJoinCondition (rexBuilder , typeFactory , input , agg , groupSet );
121+ RexNode condition = buildPartitionJoinCondition (rexBuilder , typeFactory , input , agg , grpSet );
122122
123123 RelNode join = LogicalJoin .create (
124124 input ,
@@ -281,7 +281,7 @@ private static AggregateCall toAggregateCall(
281281 .map (RexNode ::getType )
282282 .collect (Collectors .toList ());
283283
284- SqlAggFunction agg = (SqlAggFunction ) winAggCall .getOperator ();
284+ SqlAggFunction agg = (SqlAggFunction )winAggCall .getOperator ();
285285
286286 SqlOperatorBinding binding = new ExplicitOperatorBinding (typeFactory , agg , operandTypes );
287287
@@ -313,7 +313,7 @@ private static List<RexNode> buildProjection(RelNode join, LogicalWindow win, Lo
313313 RexBuilder rexBuilder = win .getCluster ().getRexBuilder ();
314314 int inputFieldCnt = win .getInput ().getRowType ().getFieldCount ();
315315
316- int groupKeyCnt = grp .keys .cardinality ();
316+ int grpKeyCnt = grp .keys .cardinality ();
317317 int aggFieldCnt = grp .aggCalls .size ();
318318
319319 List <RexNode > projects = new ArrayList <>(inputFieldCnt + aggFieldCnt );
@@ -322,7 +322,7 @@ private static List<RexNode> buildProjection(RelNode join, LogicalWindow win, Lo
322322 projects .add (rexBuilder .makeInputRef (join , i ));
323323
324324 for (int i = 0 ; i < aggFieldCnt ; i ++) {
325- RexNode ref = rexBuilder .makeInputRef (join , inputFieldCnt + groupKeyCnt + i );
325+ RexNode ref = rexBuilder .makeInputRef (join , inputFieldCnt + grpKeyCnt + i );
326326
327327 RelDataType targetType = windowAggType (win , i );
328328
0 commit comments