This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch UserDefineTime-TsFile in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f91730aa4605b628d8303616c50ce47d985d166f Merge: 7c86a31fe43 f4e8521f021 Author: Caideyipi <[email protected]> AuthorDate: Thu Jan 22 12:20:10 2026 +0800 Merge branch 'master' of https://github.com/apache/iotdb into UserDefineTime-TsFile .github/workflows/multi-language-client.yml | 13 +- distribution/pom.xml | 8 + distribution/src/assembly/all.xml | 4 + distribution/src/assembly/datanode.xml | 6 + .../src/assembly/external-service-impl.xml | 51 + example/client-cpp-example/src/CMakeLists.txt | 64 +- example/mqtt-customize/pom.xml | 6 +- .../server/CustomizedJsonPayloadFormatter.java | 6 +- ...Formatter => org.apache.iotdb.PayloadFormatter} | 0 external-service-impl/mqtt/pom.xml | 177 + .../apache/iotdb}/mqtt/BrokerAuthenticator.java | 2 +- .../apache/iotdb}/mqtt/JSONPayloadFormatter.java | 2 +- .../apache/iotdb}/mqtt/LinePayloadFormatter.java | 2 +- .../org/apache/iotdb}/mqtt/MPPPublishHandler.java | 2 +- .../java/org/apache/iotdb/mqtt}/MQTTService.java | 28 +- .../main/java/org/apache/iotdb}/mqtt/Message.java | 2 +- .../apache/iotdb}/mqtt/PayloadFormatManager.java | 2 +- .../org/apache/iotdb}/mqtt/PayloadFormatter.java | 2 +- .../java/org/apache/iotdb}/mqtt/TableMessage.java | 2 +- .../java/org/apache/iotdb}/mqtt/TreeMessage.java | 2 +- .../org.apache.iotdb.mqtt.PayloadFormatter | 4 +- .../iotdb}/mqtt/BrokerAuthenticatorTest.java | 18 +- .../iotdb}/mqtt/JSONPayloadFormatterTest.java | 3 +- .../iotdb}/mqtt/LinePayloadFormatterTest.java | 3 +- .../iotdb}/mqtt/PayloadFormatManagerTest.java | 8 +- .../pom.xml | 26 +- integration-test/pom.xml | 12 + integration-test/src/assembly/mpp-share.xml | 6 + .../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 16 + .../auto/basic/IoTDBTreePatternFormatIT.java | 13 + .../treemodel/manual/IoTDBPipeInclusionIT.java | 3 + .../org/apache/iotdb/tool/data/ExportDataTree.java | 221 +- iotdb-client/client-cpp/pom.xml | 34 +- .../client-cpp/src/main/AbstractSessionBuilder.h | 39 +- iotdb-client/client-cpp/src/main/CMakeLists.txt | 16 +- iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 73 +- iotdb-client/client-cpp/src/main/NodesSupplier.h | 34 +- iotdb-client/client-cpp/src/main/Session.cpp | 2 +- iotdb-client/client-cpp/src/main/Session.h | 4 + iotdb-client/client-cpp/src/main/SessionBuilder.h | 15 + .../client-cpp/src/main/SessionConnection.cpp | 20 +- .../client-cpp/src/main/SessionConnection.h | 5 +- .../client-cpp/src/main/TableSessionBuilder.h | 15 + .../client-cpp/src/main/ThriftConnection.cpp | 16 +- .../client-cpp/src/main/ThriftConnection.h | 6 +- iotdb-client/client-cpp/src/test/CMakeLists.txt | 42 +- iotdb-client/client-cpp/src/test/catch2/catch.hpp | 17974 +++++++++++++++++++ iotdb-client/client-cpp/src/test/main.cpp | 15 +- .../client-py/iotdb/tsfile/utils/tsblock_serde.py | 1 - .../iotdb/ainode/core/inference/pool_controller.py | 11 + .../iotdb/ainode/core/manager/inference_manager.py | 8 +- iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 12 +- .../pipe/agent/task/PipeConfigNodeSubtask.java | 27 +- .../schema/AlterTimeSeriesDataTypeProcedure.java | 2 +- iotdb-core/datanode/pom.xml | 12 - .../dataregion/DataExecutionVisitor.java | 9 +- .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 6 +- .../subtask/processor/PipeProcessorSubtask.java | 8 +- .../agent/task/subtask/sink/PipeSinkSubtask.java | 40 +- .../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +- .../sink/protocol/writeback/WriteBackSink.java | 2 +- ...istoricalDataRegionTsFileAndDeletionSource.java | 3 +- .../impl/DataNodeInternalRPCServiceImpl.java | 8 - .../queryengine/execution/QueryStateMachine.java | 2 +- .../execution/executor/RegionReadExecutor.java | 4 +- .../fragment/FragmentInstanceContext.java | 2 +- .../operator/process/function/partition/Slice.java | 6 +- .../relational/aggregation/RecordIterator.java | 6 +- .../execution/schedule/AbstractDriverThread.java | 4 +- .../queryengine/plan/execution/QueryExecution.java | 2 +- .../db/queryengine/plan/parser/ASTVisitor.java | 27 +- .../plan/node/write/RelationalInsertRowsNode.java | 43 - .../node/write/RelationalInsertTabletNode.java | 51 - .../crud/InsertMultiTabletsStatement.java | 6 +- .../schemaregion/utils/ResourceByPathUtils.java | 54 +- .../java/org/apache/iotdb/db/service/DataNode.java | 16 +- .../externalservice/BuiltinExternalServices.java | 9 +- .../ExternalServiceManagementService.java | 56 +- .../db/storageengine/dataregion/DataRegion.java | 56 - .../dataregion/modification/ModificationFile.java | 12 +- .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 14 +- .../org/apache/iotdb/db/utils/ObjectTypeUtils.java | 61 +- .../db/pipe/pattern/TreePatternPruningTest.java | 2 + .../db/pipe/source/IoTDBDataRegionSourceTest.java | 2 + .../settle/SettleCompactionTaskTest.java | 32 + .../iotdb/commons/auth/entity/TablePrivilege.java | 3 + .../commons/exception/ObjectFileNotExist.java | 6 +- ...imeSinkNonReportTimeConfigurableException.java} | 40 +- ...RuntimeSinkRetryTimesConfigurableException.java | 27 +- .../task/subtask/PipeAbstractSinkSubtask.java | 52 + .../pipe/config/constant/SystemConstant.java | 2 +- .../datastructure/pattern/IoTDBTreePattern.java | 5 + .../datastructure/pattern/PrefixTreePattern.java | 5 + .../pipe/datastructure/pattern/TreePattern.java | 18 + .../pattern/UnionIoTDBTreePattern.java | 5 + .../datastructure/pattern/UnionTreePattern.java | 5 + .../pattern/WithExclusionIoTDBTreePattern.java | 5 + .../pattern/WithExclusionTreePattern.java | 5 + .../pipe/receiver/PipeReceiverStatusHandler.java | 36 +- .../apache/iotdb/commons/service/ServiceType.java | 1 - .../ErrorHandlingCommonUtils.java} | 16 +- .../src/main/thrift/datanode.thrift | 8 - pom.xml | 1 + 103 files changed, 19182 insertions(+), 700 deletions(-)
