This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch UserDefinedTime in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 6dc33198250b3967a2ddca4944a5640c5bcbf476 Merge: 38c40b6319f afcfd7419c1 Author: JackieTien97 <[email protected]> AuthorDate: Wed Jan 28 16:17:14 2026 +0800 Merge remote-tracking branch 'origin/master' into UserDefinedTime dependencies.json | 1 - example/client-cpp-example/src/CMakeLists.txt | 157 ++++--- .../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 - .../iotdb/ainode/it/AINodeCallInferenceIT.java | 14 + .../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 7 + .../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 | 18 + .../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 235 ---------- .../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 32 +- .../it/db/it/IoTDBAuthenticationTableIT.java | 36 ++ .../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-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/sync/CnToAnSyncRequestType.java | 25 ++ .../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 +- .../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 - iotdb-core/node-commons/pom.xml | 4 - .../iotdb/commons/client/ClientPoolFactory.java | 22 + .../commons/client/sync/SyncAINodeClient.java | 153 +++++++ .../pipe/config/constant/PipeSinkConstant.java | 5 + .../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 368 --------------- pom.xml | 6 - 65 files changed, 4673 insertions(+), 2763 deletions(-)
