This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch force_ci/split_chunk in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1224142e894b9de44624d3d37a85c376e72cc47e Merge: f016492406b fc36adbb6f6 Author: HTHou <[email protected]> AuthorDate: Mon Dec 30 17:36:01 2024 +0800 Merge branch 'master' of github.com:apache/iotdb into force_ci/split_chunk .../java/org/apache/iotdb/TableHttpExample.java | 4 +- .../java/org/apache/iotdb/TableHttpsExample.java | 4 +- .../it/autocreate/IoTDBPipeAutoConflictIT.java | 51 +++ .../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 79 +++- .../it/query/recent/IoTDBTableAggregationIT.java | 28 +- .../udf/api/relational/AggregateFunction.java | 3 +- .../iotdb/consensus/ratis/RatisConsensus.java | 23 +- .../schemaregion/SchemaExecutionVisitor.java | 5 +- ...ator.java => AbstractAggTableScanOperator.java} | 223 +++++----- .../relational/DefaultAggTableScanOperator.java | 81 ++++ .../relational/LastQueryAggTableScanOperator.java | 458 +++++++++++++++++++++ .../relational/aggregation/AccumulatorFactory.java | 10 +- .../aggregation/AggregationOperator.java | 1 + .../relational/aggregation/LastAccumulator.java | 22 +- .../relational/aggregation/LastByAccumulator.java | 28 +- .../aggregation/LastByDescAccumulator.java | 5 + .../aggregation/LastDescAccumulator.java | 9 +- .../relational/aggregation/TableAccumulator.java | 4 + .../relational/aggregation/TableAggregator.java | 16 + .../UserDefinedAggregateFunctionAccumulator.java | 6 + .../aggregation/grouped/GroupedAccumulator.java | 4 + .../aggregation/grouped/GroupedAggregator.java | 4 + .../GroupedUserDefinedAggregateAccumulator.java | 6 + .../grouped/HashAggregationOperator.java | 1 + .../grouped/StreamingAggregationOperator.java | 1 + .../queryengine/plan/analyze/AnalyzeVisitor.java | 4 - .../plan/planner/OperatorTreeGenerator.java | 4 +- .../plan/planner/TableOperatorGenerator.java | 196 +++++++-- .../planner/plan/parameter/SeriesScanOptions.java | 12 + .../metadata/fetcher/TableDeviceSchemaFetcher.java | 7 +- .../service/AbstractThriftServiceThread.java | 7 +- 31 files changed, 1103 insertions(+), 203 deletions(-)
