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
from 7c86a31fe43 partial
add 50c6183a8ac sesion cpp ssl (#16968)
add f74a7dcbcd3 Fix mods name of target files in settle compaction (#17043)
add d74fca109dc Repair the problem that accumulate index used
chunkMetadataList (#17040)
add a5f87298a55 [AINode] Fix the AINode cannot stop by script (#17045)
add ec9bd0d6da0 fix session cpp node-supplier (#17039)
add 2471938c505 Pipe: Fixed the semantic of reporting interval && Trimmed
the "toString" of InsertMultiTabletsStatement (#17044)
add dce185a745b Decouple mqtt from iotdb-server using ExternalService
framework (#17042)
add d8a0a5abda8 [AINode] Optimize model loading (#17046)
add 650cc085396 remove some useless code (#17047)
add 1befb1b4fe5 Pipe: disable multiple path and path exclusion (#17038)
add 8aef1952c31 Remove some method implementations related to the object
type (#17054)
add 56097ac5b2f Fix data export logic to avoid redundant high frequency
query (#17049)
add 36dadf5d965 Upper case data type from SQL statement, and add a
validation for non exist data type. (#17057)
add f4e8521f021 Fix the problem that "StateMachineProceduree not set next
state, but return HAS_MORE_STATE". (#17058)
new f91730aa460 Merge branch 'master' of https://github.com/apache/iotdb
into UserDefineTime-TsFile
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:
.github/workflows/multi-language-client.yml | 13 +-
distribution/pom.xml | 8 +
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/datanode.xml | 6 +
...{common-files.xml => external-service-impl.xml} | 21 +-
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 | 3 +-
.../iotdb}/mqtt/BrokerAuthenticatorTest.java | 18 +-
.../iotdb}/mqtt/JSONPayloadFormatterTest.java | 3 +-
.../iotdb}/mqtt/LinePayloadFormatterTest.java | 3 +-
.../iotdb}/mqtt/PayloadFormatManagerTest.java | 8 +-
{example/jdbc => external-service-impl}/pom.xml | 28 +-
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 +-
....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 21 -
.../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 +-
.../exception/pipe/PipeNonReportException.java | 27 -
...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 -
.../commons/utils/ErrorHandlingCommonUtils.java} | 14 +-
.../src/main/thrift/datanode.thrift | 8 -
pom.xml | 1 +
105 files changed, 19126 insertions(+), 773 deletions(-)
copy distribution/src/assembly/{common-files.xml => external-service-impl.xml}
(71%)
copy
example/mqtt-customize/src/main/resources/META-INF/services/{org.apache.iotdb.db.protocol.mqtt.PayloadFormatter
=> org.apache.iotdb.PayloadFormatter} (100%)
create mode 100644 external-service-impl/mqtt/pom.xml
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/BrokerAuthenticator.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/JSONPayloadFormatter.java
(99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/LinePayloadFormatter.java
(99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/MPPPublishHandler.java
(99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb/mqtt}/MQTTService.java
(84%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/Message.java
(96%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/PayloadFormatManager.java
(99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/PayloadFormatter.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/TableMessage.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/main/java/org/apache/iotdb}/mqtt/TreeMessage.java
(97%)
rename
example/mqtt-customize/src/main/resources/META-INF/services/org.apache.iotdb.db.protocol.mqtt.PayloadFormatter
=>
external-service-impl/mqtt/src/main/resources/META-INF/services/org.apache.iotdb.mqtt.PayloadFormatter
(90%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/test/java/org/apache/iotdb}/mqtt/BrokerAuthenticatorTest.java
(77%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/test/java/org/apache/iotdb}/mqtt/JSONPayloadFormatterTest.java
(99%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/test/java/org/apache/iotdb}/mqtt/LinePayloadFormatterTest.java
(98%)
rename {iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol =>
external-service-impl/mqtt/src/test/java/org/apache/iotdb}/mqtt/PayloadFormatManagerTest.java
(84%)
copy {example/jdbc => external-service-impl}/pom.xml (71%)
create mode 100644 iotdb-client/client-cpp/src/test/catch2/catch.hpp
delete mode 100644
iotdb-core/datanode/src/main/resources/META-INF/services/org.apache.iotdb.db.protocol.mqtt.PayloadFormatter
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeNonReportException.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/function/LongVariableConstraint.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/exception/pipe/PipeRuntimeSinkNonReportTimeConfigurableException.java}
(54%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/exception/runtime/MemoryLeakException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/ErrorHandlingCommonUtils.java}
(74%)
