This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch force_ci/split_chunk
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f016492406b Merge branch 'master' into split_text_chunk
add d83dd4f5e24 Pipe: Ensure the idempotency of the historical activation
batch (#14566)
add e95f4c5869a Bind 0.0.0.0 for all Thrift Service to enhance
extensibility #14577
add 554d7d86978 Close Aggregation and State to release resource
add d865a2c24e3 Fix RatisConsensus client==null exception when stopping
datanode #14578
add 94e0f30598f Parameter Naming Adjustment for the Table Model of REST
Service example (#14575)
add 4f19e6c3720 Use schema last cache to speed up the last and last_by
aggregations in table model
add fc36adbb6f6 Fixed the timeout of device schema fetch to the timeout of
the caller query/write operation
new 1224142e894 Merge branch 'master' of github.com:apache/iotdb into
force_ci/split_chunk
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../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(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{TableAggregationTableScanOperator.java
=> AbstractAggTableScanOperator.java} (87%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/DefaultAggTableScanOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/LastQueryAggTableScanOperator.java
