This is an automated email from the ASF dual-hosted git repository. justinchen pushed a change to branch UserDefineTime-TsFile in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 5c3959c6bce fix discard 5797ccef08f fix discard 786d47e0942 sfy discard 4859b722b7b Partial discard 3c1821380ef Update TableHeaderSchemaValidator.java discard f91730aa460 Merge branch 'master' of https://github.com/apache/iotdb into UserDefineTime-TsFile omit f4e8521f021 Fix the problem that "StateMachineProceduree not set next state, but return HAS_MORE_STATE". (#17058) omit 36dadf5d965 Upper case data type from SQL statement, and add a validation for non exist data type. (#17057) discard 7c86a31fe43 partial omit 56097ac5b2f Fix data export logic to avoid redundant high frequency query (#17049) discard 3b4ff49edfb fix discard e8355f9364a ref omit 8aef1952c31 Remove some method implementations related to the object type (#17054) omit 1befb1b4fe5 Pipe: disable multiple path and path exclusion (#17038) omit 650cc085396 remove some useless code (#17047) omit d8a0a5abda8 [AINode] Optimize model loading (#17046) omit dce185a745b Decouple mqtt from iotdb-server using ExternalService framework (#17042) omit 2471938c505 Pipe: Fixed the semantic of reporting interval && Trimmed the "toString" of InsertMultiTabletsStatement (#17044) omit ec9bd0d6da0 fix session cpp node-supplier (#17039) omit a5f87298a55 [AINode] Fix the AINode cannot stop by script (#17045) omit d74fca109dc Repair the problem that accumulate index used chunkMetadataList (#17040) omit f74a7dcbcd3 Fix mods name of target files in settle compaction (#17043) omit 50c6183a8ac sesion cpp ssl (#16968) This update removed existing revisions from the reference, leaving the reference pointing at a previous point in the repository history. * -- * -- N refs/heads/UserDefineTime-TsFile (0aa1d9c3677) \ O -- O -- O (5c3959c6bce) Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .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 +- ...apache.iotdb.db.protocol.mqtt.PayloadFormatter} | 0 external-service-impl/mqtt/pom.xml | 177 - external-service-impl/pom.xml | 53 - 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 +- .../db/protocol}/mqtt/BrokerAuthenticator.java | 2 +- .../db/protocol}/mqtt/JSONPayloadFormatter.java | 2 +- .../db/protocol}/mqtt/LinePayloadFormatter.java | 2 +- .../iotdb/db/protocol}/mqtt/MPPPublishHandler.java | 2 +- .../apache/iotdb/db/protocol}/mqtt/Message.java | 2 +- .../db/protocol}/mqtt/PayloadFormatManager.java | 2 +- .../iotdb/db/protocol}/mqtt/PayloadFormatter.java | 2 +- .../iotdb/db/protocol}/mqtt/TableMessage.java | 2 +- .../iotdb/db/protocol}/mqtt/TreeMessage.java | 2 +- .../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 +- .../plan/analyze/load/LoadTsFileAnalyzer.java | 3 - .../analyze/load/LoadTsFileTableSchemaCache.java | 12 +- .../queryengine/plan/execution/QueryExecution.java | 2 +- .../db/queryengine/plan/parser/ASTVisitor.java | 27 +- .../plan/planner/LogicalPlanVisitor.java | 3 +- .../plan/node/load/LoadSingleTsFileNode.java | 18 +- .../planner/plan/node/load/LoadTsFileNode.java | 14 +- .../plan/node/write/RelationalInsertRowsNode.java | 43 + .../node/write/RelationalInsertTabletNode.java | 51 + .../plan/relational/metadata/Metadata.java | 22 +- .../relational/metadata/TableMetadataImpl.java | 23 +- .../fetcher/TableHeaderSchemaValidator.java | 66 +- .../plan/relational/planner/RelationPlanner.java | 6 +- .../plan/relational/sql/ast/LoadTsFile.java | 11 +- .../crud/InsertMultiTabletsStatement.java | 6 +- .../schemaregion/utils/ResourceByPathUtils.java | 54 +- .../java/org/apache/iotdb/db/service/DataNode.java | 16 +- .../org/apache/iotdb/db/service}/MQTTService.java | 28 +- .../externalservice/BuiltinExternalServices.java | 9 +- .../ExternalServiceManagementService.java | 56 +- .../db/storageengine/dataregion/DataRegion.java | 56 + .../dataregion/modification/ModificationFile.java | 12 +- .../db/storageengine/load/LoadTsFileManager.java | 6 +- .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 14 +- .../org/apache/iotdb/db/utils/ObjectTypeUtils.java | 61 +- ....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 4 +- .../db/pipe/pattern/TreePatternPruningTest.java | 2 - .../db/pipe/source/IoTDBDataRegionSourceTest.java | 2 - .../db/protocol}/mqtt/BrokerAuthenticatorTest.java | 18 +- .../protocol}/mqtt/JSONPayloadFormatterTest.java | 3 +- .../protocol}/mqtt/LinePayloadFormatterTest.java | 3 +- .../protocol}/mqtt/PayloadFormatManagerTest.java | 8 +- .../plan/planner/node/load/LoadTsFileNodeTest.java | 2 +- .../plan/relational/analyzer/AnalyzerTest.java | 6 +- .../plan/relational/analyzer/TSBSMetadata.java | 6 +- .../plan/relational/analyzer/TestMetadata.java | 6 +- .../plan/statement/InsertStatementTest.java | 16 +- .../settle/SettleCompactionTaskTest.java | 32 - .../iotdb/commons/auth/entity/TablePrivilege.java | 3 - .../commons/exception/ObjectFileNotExist.java | 6 +- .../exception/pipe/PipeNonReportException.java | 6 +- ...timeSinkNonReportTimeConfigurableException.java | 66 - ...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/schema/table/TsTable.java | 2 +- .../apache/iotdb/commons/service/ServiceType.java | 1 + .../commons/utils/ErrorHandlingCommonUtils.java | 33 - .../src/main/thrift/datanode.thrift | 8 + pom.xml | 1 - 121 files changed, 744 insertions(+), 19436 deletions(-) delete mode 100644 distribution/src/assembly/external-service-impl.xml rename example/mqtt-customize/src/main/resources/META-INF/services/{org.apache.iotdb.PayloadFormatter => org.apache.iotdb.db.protocol.mqtt.PayloadFormatter} (100%) delete mode 100644 external-service-impl/mqtt/pom.xml delete mode 100644 external-service-impl/pom.xml delete mode 100644 iotdb-client/client-cpp/src/test/catch2/catch.hpp rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/BrokerAuthenticator.java (97%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/JSONPayloadFormatter.java (99%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/LinePayloadFormatter.java (99%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/MPPPublishHandler.java (99%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/Message.java (96%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/PayloadFormatManager.java (99%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/PayloadFormatter.java (97%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/TableMessage.java (98%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol}/mqtt/TreeMessage.java (97%) rename {external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt => iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service}/MQTTService.java (84%) rename external-service-impl/mqtt/src/main/resources/META-INF/services/org.apache.iotdb.mqtt.PayloadFormatter => iotdb-core/datanode/src/main/resources/META-INF/services/org.apache.iotdb.db.protocol.mqtt.PayloadFormatter (87%) rename {external-service-impl/mqtt/src/test/java/org/apache/iotdb => iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol}/mqtt/BrokerAuthenticatorTest.java (77%) rename {external-service-impl/mqtt/src/test/java/org/apache/iotdb => iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol}/mqtt/JSONPayloadFormatterTest.java (99%) rename {external-service-impl/mqtt/src/test/java/org/apache/iotdb => iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol}/mqtt/LinePayloadFormatterTest.java (98%) rename {external-service-impl/mqtt/src/test/java/org/apache/iotdb => iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol}/mqtt/PayloadFormatManagerTest.java (84%) copy iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/PipeParameterNotValidException.java => iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeNonReportException.java (82%) delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkNonReportTimeConfigurableException.java delete mode 100644 iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/utils/ErrorHandlingCommonUtils.java
