AMashenkov commented on code in PR #2443:
URL: https://github.com/apache/ignite-3/pull/2443#discussion_r1298670612
##########
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/AbstractSetOpNode.java:
##########
@@ -195,62 +196,77 @@ private void flush() throws Exception {
}
/**
- * Grouping.
- * TODO Documentation https://issues.apache.org/jira/browse/IGNITE-15859
+ * Grouping provides base driver code to implement a set operator.
+ *
+ * <p>The basic idea is to store the number of distinct rows per input set
and use these numbers to calculate
+ * the number of rows an operator should produce.
*/
protected abstract static class Grouping<RowT> {
protected final Map<GroupKey, int[]> groups = new HashMap<>();
- protected final RowHandler<RowT> hnd;
-
protected final AggregateType type;
protected final boolean all;
protected final RowFactory<RowT> rowFactory;
- /** Processed rows count in current set. */
- protected int rowsCnt = 0;
+ private final RowHandler<RowT> hnd;
+
+ private final int columnNum;
Review Comment:
Please specify, is row columns or group key column or whatever?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
