This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/support_schema_evolution
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c25ab492e85 trigger ci
add 537c3b05fe1 Revert "remove unused dependenccy"
add 8d42a9276d6 add back checker
add b7c12a20116 Improve stability of BinaryAllocatorTest#testEviction
(#17078)
add d9c3fc9f908 fix: record directory allocation for hard-linked files
(#17077)
add 6952ebf4dc3 Fix Python & Go Client CI (#17081)
add 8e5fcba50ba Fix cross partition write after alter data type (#17082)
add 2e46872766b Support stream DataFrame interface in iotdb python client
(#17035)
add 465170bac57 Adjust error message (#17084)
add d90397dc1ff [AINode] Call inference should only contain 1 input column
(#17087)
add 81f8e7e1fa3 [AINode] Fix the bug that AINode would not stop during
remove process (#17088)
add 0b25ea24c9c Support NULL time in First/Last/FirstBy/LastBy
aggregations (#17064)
add d06bced6c3a Support session with CPP conditional compilation for SSL.
(#17080)
add 82f7ca6dfc5 Pipe: Fixed the OPC UA client connection problem (#17083)
add b40b74b31ea Remove built-in jexl function in tree mode (#17092)
add 5802fa2e0ab Resolve the problem that everyone can alter table column
data type. (#17089)
add 8289238b119 Fix init time logic to ensure that time is not initiated‌
when the last cache will not updated during the execution phase (#17094)
add 52715f18e48 Verify nonexist measurement in an exist device if it
exists. (#17093)
add afcfd7419c1 fix (#17096)
add 91e5ed54126 Merge branch 'master' into
force_ci/support_schema_evolution
add 11054f94e8c Fix allValueColDeletedMap index out of bound caused by
stale rowCount after TVList sort (#17098)
add d05276e2955 Decouple rest from iotdb-server using ExternalService
framework (#17099)
add dad8ec8824e Remove text involve DataNodeId when assert two results.
(#17107)
add 12b5bc3e9af Fix binary allocator test & querying type-altered chunks
in memory may affect the result of flush (#17105)
add 498197b31e4 Add mqtt IT for json mode. (#17090)
add d28d71c2eb0 Merge branch 'master' into
force_ci/support_schema_evolution
add aba65887fe8 fix not overridden method
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 2 +-
dependencies.json | 2 +-
distribution/pom.xml | 6 +
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/datanode.xml | 4 +
.../src/assembly/external-service-impl.xml | 4 +
docker/src/main/Dockerfile-1c1d | 4 +-
example/client-cpp-example/src/CMakeLists.txt | 157 ++--
external-service-impl/pom.xml | 2 +
.../rest-openapi}/pom.xml | 34 +-
.../src/main/openapi3/iotdb_rest_common.yaml | 0
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 0
.../src/main/openapi3/iotdb_rest_v1.yaml | 0
.../src/main/openapi3/iotdb_rest_v2.yaml | 0
external-service-impl/{mqtt => rest}/pom.xml | 153 ++--
.../java/org/apache/iotdb/rest}/RestService.java | 30 +-
.../rest/protocol}/filter/ApiOriginFilter.java | 2 +-
.../rest/protocol}/filter/AuthorizationFilter.java | 4 +-
.../protocol}/filter/BasicSecurityContext.java | 2 +-
.../apache/iotdb/rest/protocol}/filter/User.java | 2 +-
.../iotdb/rest/protocol}/filter/UserCache.java | 2 +-
.../protocol}/handler/AuthorizationHandler.java | 4 +-
.../rest/protocol}/impl/PingApiServiceImpl.java | 6 +-
.../table/v1/handler/ExceptionHandler.java | 4 +-
.../table/v1/handler/ExecuteStatementHandler.java | 2 +-
.../table/v1/handler/QueryDataSetHandler.java | 6 +-
.../table/v1/handler/RequestValidationHandler.java | 6 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../table/v1/impl/RestApiServiceImpl.java | 26 +-
.../rest/protocol}/utils/InsertRowDataUtils.java | 2 +-
.../protocol}/utils/InsertTabletSortDataUtils.java | 2 +-
.../protocol/v1}/handler/ExceptionHandler.java | 4 +-
.../v1/handler/ExecuteStatementHandler.java | 2 +-
.../protocol}/v1/handler/QueryDataSetHandler.java | 26 +-
.../v1/handler/RequestValidationHandler.java | 8 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../protocol}/v1/impl/GrafanaApiServiceImpl.java | 18 +-
.../rest/protocol}/v1/impl/RestApiServiceImpl.java | 32 +-
.../protocol/v2}/handler/ExceptionHandler.java | 4 +-
.../v2/handler/ExecuteStatementHandler.java | 2 +-
.../rest/protocol}/v2/handler/FastLastHandler.java | 10 +-
.../protocol}/v2/handler/QueryDataSetHandler.java | 22 +-
.../v2/handler/RequestValidationHandler.java | 12 +-
.../v2/handler/StatementConstructionHandler.java | 8 +-
.../protocol}/v2/impl/GrafanaApiServiceImpl.java | 18 +-
.../rest/protocol}/v2/impl/RestApiServiceImpl.java | 36 +-
integration-test/pom.xml | 7 +
integration-test/src/assembly/mpp-share.xml | 4 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 2 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 -
.../iotdb/ainode/it/AINodeCallInferenceIT.java | 14 +
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 7 +
.../iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java | 363 ++++++++
.../db/it/query/IoTDBAggregationFirstByIT.java | 162 ++++
.../it/query/IoTDBAggregationFirstByInGroupIT.java | 139 ++++
.../iotdb/db/it/query/IoTDBAggregationFirstIT.java | 185 +++++
.../it/query/IoTDBAggregationFirstInGroupIT.java | 134 +++
.../db/it/query/IoTDBAggregationLastByIT.java | 164 ++++
.../it/query/IoTDBAggregationLastByInGroupIT.java | 136 +++
.../iotdb/db/it/query/IoTDBAggregationLastIT.java | 176 ++++
.../db/it/query/IoTDBAggregationLastInGroupIT.java | 128 +++
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 54 ++
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 235 ------
.../treemodel/manual/IoTDBPipePermissionIT.java | 42 +
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 32 +-
.../it/db/it/IoTDBAuthenticationTableIT.java | 36 +
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 1 +
.../it/query/recent/IoTDBTableAggregationIT.java | 9 +
iotdb-client/client-cpp/pom.xml | 3 +
iotdb-client/client-cpp/src/main/CMakeLists.txt | 51 +-
.../client-cpp/src/main/SessionConnection.cpp | 6 +
.../client-cpp/src/main/SessionConnection.h | 6 +-
.../client-cpp/src/main/ThriftConnection.cpp | 6 +
.../client-cpp/src/main/ThriftConnection.h | 4 +
iotdb-client/client-cpp/src/test/CMakeLists.txt | 92 ++-
iotdb-client/client-go | 2 +-
iotdb-client/client-py/iotdb/Session.py | 8 +-
.../client-py/iotdb/utils/SessionDataSet.py | 19 +
.../client-py/iotdb/utils/iotdb_rpc_dataset.py | 68 ++
iotdb-client/client-py/session_example.py | 6 +
.../client-py/table_model_session_example.py | 4 +
.../client-py/tests/integration/test_dataframe.py | 50 ++
.../client-py/tests/integration/test_todf.py | 2 +-
iotdb-core/confignode/pom.xml | 6 -
.../client/sync/CnToAnSyncRequestType.java | 7 +-
.../client/sync/SyncAINodeClientPool.java | 151 ++++
.../consensus/request/ConfigPhysicalPlanType.java | 1 -
.../pipe/source/ConfigRegionListeningFilter.java | 2 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 22 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 48 +-
iotdb-core/datanode/pom.xml | 58 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 79 +-
.../sink/protocol/opcua/client/ClientRunner.java | 51 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 34 +-
.../operator/process/ai/InferenceOperator.java | 7 +
.../relational/LastQueryAggTableScanOperator.java | 64 +-
.../relational/aggregation/FirstAccumulator.java | 445 ++++++----
.../relational/aggregation/FirstByAccumulator.java | 494 +++++------
.../aggregation/FirstByDescAccumulator.java | 180 ++--
.../aggregation/FirstDescAccumulator.java | 168 ++--
.../relational/aggregation/LastAccumulator.java | 373 +++++----
.../relational/aggregation/LastByAccumulator.java | 442 +++++-----
.../aggregation/LastByDescAccumulator.java | 234 +++---
.../aggregation/LastDescAccumulator.java | 198 +++--
.../source/relational/aggregation/Utils.java | 39 +-
.../grouped/GroupedFirstAccumulator.java | 390 +++++----
.../grouped/GroupedFirstByAccumulator.java | 473 ++++++-----
.../grouped/GroupedLastAccumulator.java | 390 +++++----
.../grouped/GroupedLastByAccumulator.java | 476 ++++++-----
.../execution/config/TableConfigTaskVisitor.java | 4 +
.../config/executor/ClusterConfigTaskExecutor.java | 23 +-
.../plan/planner/TableOperatorGenerator.java | 6 +-
.../udf/BuiltinTimeSeriesGeneratingFunction.java | 2 -
.../java/org/apache/iotdb/db/service/DataNode.java | 4 -
.../externalservice/BuiltinExternalServices.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 13 +-
.../FirstBatchCompactionAlignedChunkWriter.java | 13 +
...FollowingBatchCompactionAlignedChunkWriter.java | 16 +
.../memtable/AlignedReadOnlyMemChunk.java | 12 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 4 +-
.../dataregion/snapshot/SnapshotLoader.java | 1 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 5 +-
.../db/utils/datastructure/AlignedTVList.java | 6 +-
.../db/utils/datastructure/BackAlignedTVList.java | 3 +-
.../db/utils/datastructure/BackBinaryTVList.java | 3 +-
.../db/utils/datastructure/BackBooleanTVList.java | 3 +-
.../db/utils/datastructure/BackDoubleTVList.java | 3 +-
.../db/utils/datastructure/BackFloatTVList.java | 3 +-
.../db/utils/datastructure/BackIntTVList.java | 3 +-
.../db/utils/datastructure/BackLongTVList.java | 3 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 3 +-
.../db/utils/datastructure/QuickBinaryTVList.java | 3 +-
.../db/utils/datastructure/QuickBooleanTVList.java | 3 +-
.../db/utils/datastructure/QuickDoubleTVList.java | 3 +-
.../db/utils/datastructure/QuickFloatTVList.java | 3 +-
.../db/utils/datastructure/QuickIntTVList.java | 3 +-
.../db/utils/datastructure/QuickLongTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../db/utils/datastructure/TimAlignedTVList.java | 3 +-
.../db/utils/datastructure/TimBinaryTVList.java | 3 +-
.../db/utils/datastructure/TimBooleanTVList.java | 3 +-
.../db/utils/datastructure/TimDoubleTVList.java | 3 +-
.../db/utils/datastructure/TimFloatTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 3 +-
.../db/utils/datastructure/TimLongTVList.java | 3 +-
.../db/protocol/rest/GrafanaApiServiceTest.java | 450 ----------
.../db/protocol/rest/IoTDBRestServiceTest.java | 918 ---------------------
.../dataregion/memtable/PrimitiveMemTableTest.java | 57 ++
.../dataregion/snapshot/IoTDBSnapshotTest.java | 78 ++
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 18 +-
iotdb-core/node-commons/pom.xml | 4 -
.../iotdb/commons/binaryallocator/arena/Arena.java | 7 +-
.../iotdb/commons/client/ClientPoolFactory.java | 22 +
...susServiceClient.java => SyncAINodeClient.java} | 56 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 3 +-
.../pipe/config/constant/PipeSinkConstant.java | 5 +
.../apache/iotdb/commons/service/ServiceType.java | 1 -
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 368 ---------
.../binaryallocator/BinaryAllocatorTest.java | 10 +-
iotdb-protocol/pom.xml | 1 -
pom.xml | 6 -
161 files changed, 5538 insertions(+), 4516 deletions(-)
rename {iotdb-protocol/openapi => external-service-impl/rest-openapi}/pom.xml
(87%)
rename {iotdb-protocol/openapi =>
external-service-impl/rest-openapi}/src/main/openapi3/iotdb_rest_common.yaml
(100%)
rename {iotdb-protocol/openapi =>
external-service-impl/rest-openapi}/src/main/openapi3/iotdb_rest_table_v1.yaml
(100%)
rename {iotdb-protocol/openapi =>
external-service-impl/rest-openapi}/src/main/openapi3/iotdb_rest_v1.yaml (100%)
rename {iotdb-protocol/openapi =>
external-service-impl/rest-openapi}/src/main/openapi3/iotdb_rest_v2.yaml (100%)
copy external-service-impl/{mqtt => rest}/pom.xml (59%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest}/RestService.java
(87%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/ApiOriginFilter.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/AuthorizationFilter.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/BasicSecurityContext.java
(96%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/User.java
(96%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/UserCache.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/handler/AuthorizationHandler.java
(93%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/impl/PingApiServiceImpl.java
(91%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/ExceptionHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/ExecuteStatementHandler.java
(99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/QueryDataSetHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/RequestValidationHandler.java
(95%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/StatementConstructionHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/impl/RestApiServiceImpl.java
(92%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/utils/InsertRowDataUtils.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/utils/InsertTabletSortDataUtils.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v2
=>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v1}/handler/ExceptionHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/handler/ExecuteStatementHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/handler/QueryDataSetHandler.java
(93%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/handler/RequestValidationHandler.java
(90%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/handler/StatementConstructionHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/impl/GrafanaApiServiceImpl.java
(94%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/impl/RestApiServiceImpl.java
(91%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v1
=>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v2}/handler/ExceptionHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/ExecuteStatementHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/FastLastHandler.java
(87%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/QueryDataSetHandler.java
(94%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/RequestValidationHandler.java
(93%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/StatementConstructionHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/impl/GrafanaApiServiceImpl.java
(94%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/impl/RestApiServiceImpl.java
(94%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstByIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstByInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastByIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastByInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastInGroupIT.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2SubscriptionTreeRegressionMisc.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/CnToAnSyncRequestType.java
(86%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncAINodeClientPool.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/GrafanaApiServiceTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/IoTDBRestServiceTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/{SyncPipeConsensusServiceClient.java
=> SyncAINodeClient.java} (73%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFJexl.java
