You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2024/10/17 11:29:10 UTC
(iotdb) branch master updated (b2f99d18430 -> c802367a4d7)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b2f99d18430 Pipe: Support syncing table model data between clusters (receiver fixup) & Add redirect info for PipeEnrich statements (#13797)
add c802367a4d7 Add max,min and first aggregation support for table model
No new revisions were added by this update.
Summary of changes:
.../db/it/IoTDBMultiIDsWithAttributesTableIT.java | 43 ++-
.../TableAggregationTableScanOperator.java | 36 ---
.../relational/aggregation/AccumulatorFactory.java | 6 +
...{LastAccumulator.java => FirstAccumulator.java} | 148 ++++-----
.../relational/aggregation/LastAccumulator.java | 3 +-
.../relational/aggregation/MaxAccumulator.java | 332 +++++++++++++++++++++
.../relational/aggregation/MinAccumulator.java | 332 +++++++++++++++++++++
.../thrift-commons/src/main/thrift/common.thrift | 4 +-
8 files changed, 790 insertions(+), 114 deletions(-)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{LastAccumulator.java => FirstAccumulator.java} (66%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/MaxAccumulator.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/MinAccumulator.java