This is an automated email from the ASF dual-hosted git repository.
lancelly pushed a change to branch support_correlated_scalar_subquery
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 0bce073b1fd add IT and fix assignUniqueId
add 8e61e3072ab Remove JDBC sensitive information output (#14857)
add 1deffc58907 Pipe: Fix the issue where the pipe still forwards insert
events in the table model when forwarding-pipe-requests is false (#14861)
add 330a683242d Pipe: Implement force forwarding feature where the Pipe
sender can force the receiver to forward the received event (#14847)
add 3cc339bd47a Pipe: Introduce timely flush options & Execute flush after
pipe watchdog restarts & Log degrade reasons for debugging (#14865)
add cb03ad80653 Subscription: fix consumer infinite pulling event & fully
managed tsfile parsing process & increase the reference count for subscribed
parsed raw tablet event & disrupt parsing requests through the introduction of
randomness & disable prefetch by default (#14856)
add 92bb0a19f0a Pipe IT: explicitly declare `setUp` method for test class
to avoid `UNKNOWN-IT` test class name (#14874)
add 2c4acfc1af8 Add query metrics AGGREGATION_FROM_RAW_DATA and
AGGREGATION_FROM_STATISTICS for table model
add f2c1a2a68b7 Pipe: Fixed the bug that delete timeSeries / logicalView
cannot be transferred (#14867)
add b4cec03c26f [remove datanode] Delete the SQL of removing multiple
datanodes at the same time #14862
add 0cce0e277d6 Fix TableModelJDBCExample (#14878)
add 692b6bf4d8a Pipe: Fixed the DataNode startup failure caused by Pipe
plugin loading (#14816)
add 33c9e3a1a54 fix table deletion with time predicate (#14870)
add 5f259bacc63 Remove attribute columns after attributes are updated
(#14721)
add dc8418277ab Fix insert/load with timestamp of Long.MIN_VALUE and
LONG.MAX_VALUE (#14491)
add 9e973b751cf Fix IoTConsensus safe deleted index (#14883)
add adba099046c Pipe: bind memory block for PipeTransferTsFileHandler and
PipeInsertNodeTabletInsertionEvent & unify the memory threshold judgment for
tablet and tsfile block & close data container when internally decrease
reference count of PipeTsFileInsertionEvent (#14873)
add 85f85cec61d Pipe: Optimize the data logic of distinguishing table
model and tree model (#14803)
add f8082c651aa Pipe: Reduce degrade log from
PipeRealtimeDataRegionHybridExtractor (#14888)
add 2964bd20079 Pipe: Fixed the bug that the create/delete database cannot
be passed to the receiver & SchemaRegionSnapshot parsing failure & The
historical table/databases cannot be transferred & The class cast exception at
receiver (#14876)
add 7883265abcc Fix the incorrect configuration of the JAVA_HOME
environment variable in script." (#14893)
add 4e0ecc24541 Add Date and Float data IT (#14892)
add 4aadc09fb20 Fix IoTConsensus safe deleted index again (#14897)
add 7b588c81b17 Pipe: fix threshold judgment for tablet and tsfile memory
block & Subscription: close data container for current PipeTsFileInsertionEvent
in batch (#14901)
add 897e989261d Fixed the bug that procedure rollback may generate NPE &&
some of the rollback steps may not be / be extra executed (#14871)
add 065a58d68bd Subscription: add methods to obtain the consumer
identifier in the top-level interface (#14904)
add 8760e10b796 Pipe: Avoid stuck in insertion process because failed to
allocate memory (#14899)
add 66f1daefcfa Merge branch 'master' into
support_correlated_scalar_subquery
add 8e4fef3b8f0 Update dockerfile to use the latest ubuntu 24 (#14903)
add 7615222e8fe Subscription: close memory block for previous tsfile
response (#14909)
add b8438dd0165 Add connection_time_out_in_ms for Python SDK (#14898)
add 43ed88f4909 Allow to write time column only (#14703)
add 9a93a0e29f1 Reject inserting invalid timestamp string (#14913)
add 547e7f6f6b8 Initialize WALNode when DataRegion is created for iotv1
and iotv2 (#14918)
add 85326097340 Memtable enhancement for query (#14591)
add 481a79d3c14 Fix that failure of one row in relational InsertRows will
fail other rows (#14912)
add b498285c4f4 Pipe: Modify MaxAllowedPinnedMemTableCount to adapt to
changes in the number of DRs & Modify the implementation of the poll method in
PipeRealtimePriorityBlockingQueue to reduce commit queue backlog & Adjust the
default thread count related to Pipe for better performance & Significantly
reduce pipeMemoryAllocateRetryIntervalMs & Provide a switch for memory control
of ConnectorReadFileBuffer (#14917)
add 650bbcc25f7 [RTO/RPO] Unify retry logic on SessionConnection (#14894)
add 61576c0a5bc Implemented JDBC for IoTDB based on tables
add 083ae4858fa Fix IT names & Fix region operation related IT (#14905)
add 4d965e9d6ec Don't log known error's exception thread stack
add 6b5e5b00e4c [To Master] MQTT Extensions to the Table Model Using the
Row Protocol (#14848)
add babc2af50ee Replace ExportTsFile By SubscriptionTsFile (#14812)
add ca8482a7bb1 Improve authority control of cluster management (#14924)
add 69a4eb2897b Subscription: avoid null pointer exception when get
current response due to concurrent operations (#14926)
add 82624e21d5f Load: auto detect TsFile's model (tree/table) (#14751)
add 4866f6d2cfa Add logs for PartitionTableAutoCleaner (#14934)
add 57ce941d889 Load: Add mods file metrics count (#14930)
add a864d9fabc4 Fix class name of RPCServiceMBean #14940
add bb8a5f74356 Pipe: Fix the protential resource leak issue of async
client when async manager is closed (#14929)
add 72dd41d62ed Pipe: Add memory control mechanism for TsFile batch mode
in sinks (#14911)
add 9733c7540cf Delete remove node logic in ServerCommandLine #14933
add ab2ab36fa7d Subscription: check if all topic messages have been
consumed when client polling (#14937)
add 5d38f0c251e Fix the missing deletion when concurrent deletion and
insertion compaction (#14955)
add dbe2d37c389 enhance wal compatibility (#14954)
add de10ea78911 [AINode] Optimize the error information when dropping
built-in model (#14943)
add fa9711e1146 IoTConsensusV2: Use custom commitIndex to indicate
synchronization progress instead of pipe's commitIndex (#14624)
add 29cc71b599f Add timestamp suffix to vulnerability check report.
(#14960)
add fb2cb7a394b Fix state setting of AbstractOperatePipeProcedureV2 &
Enhance state checking of StateMachineProcedure #14959
add 9e79d85b7a8 peformance regression of sequential inserting (#14951)
add 95972550d8c Introduce flushing on specific regions & IoTConsensusV2:
Flush old leader when leader transfer & Delay the execution of
invalidateSchemaCache after leader change (#14910)
add f6c3c5da617 Adapt to Mybatis generator (#14936)
add 1e6513b1fc5 IoTConsensusV2: Multi-Dirs balance with sequence rolling
strategy in receiver (#14962)
add e1840d0ea7a [IoTConsensus] More accurate statistics on IoTConsensus
memory management (#14965)
add 56080ee2f58 Revert "Allow to write time column only (#14703)" (#14967)
add b638a70a4cc Pipe: Reduce the frequency of printing logs when
AirGapConnector connection fails (#14949)
add a94ae439dde Fix the support of MQTT with java8 (#14968)
add f1a224e56c1 Subscription: unify tablet push consumer builder return
type (#14971)
add ede623a27d8 Pipe: Implemented OPC DA Sink for local COM & Fixed the
newest value of OPC UA Sink (#14964)
add 2a77b7ab162 Pipe: Optimize the TsFile memory control mechanism of the
disassembly table model (#14890)
add aad2caa9f22 Fix flush old leader NPE when rebanlce #14981
add 3384bd69a92 Subscription: add parameter to the clean up method to
distinguish the force close situation & fix reference count management for
iteration snapshot (#14966)
add a1b9f7938af [Table Model Subquery] Support Exists subquery
add 9ffef99a2ea Pipe: Make client-server the default setting of
opc-ua-sink (#14979)
add c1723158ebc [To Master] Adds extensibility to MQTT's table (#14976)
add c50cff459c4 merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/todos-check.yml | 20 +-
.github/workflows/vulnerability-check.yml | 7 +-
dependencies.json | 1 +
docker/src/main/DockerCompose/do-docker-build.sh | 4 +-
docker/src/main/Dockerfile-1.0.0-confignode | 2 +-
docker/src/main/Dockerfile-1.0.0-datanode | 2 +-
docker/src/main/Dockerfile-1.0.0-standalone | 2 +-
docker/src/main/Dockerfile-1c1d | 2 +-
.../org/apache/iotdb/TableModelJDBCExample.java | 4 +-
.../server/CustomizedJsonPayloadFormatter.java | 8 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 39 +-
.../java/org/apache/iotdb/CountPointProcessor.java | 3 +-
.../apache/iotdb/SubscriptionSessionExample.java | 2 +-
.../TableModelSubscriptionSessionExample.java | 16 +-
integration-test/pom.xml | 4 +
.../iotdb/it/env/cluster/ClusterConstant.java | 1 +
.../it/env/cluster/config/MppCommonConfig.java | 10 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../env/cluster/config/MppSharedCommonConfig.java | 13 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 11 +
.../it/env/remote/config/RemoteCommonConfig.java | 7 +-
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +-
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 2 +
.../{AbstractScript.java => AbstractScriptIT.java} | 2 +-
.../apache/iotdb/cli/it/StartClientScriptIT.java | 2 +-
....java => IoTDBAutoRegionGroupExtension2IT.java} | 4 +-
...st.java => IoTDBPartitionTableAutoCleanIT.java} | 2 +-
...IoTDBRegionOperationReliabilityITFramework.java | 72 -
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 20 +-
...IoTDBRegionMigrateNormalITForIoTV2BatchIT.java} | 2 +-
...=> IoTDBRegionMigrateOtherForIoTV2BatchIT.java} | 2 +-
... IoTDBRegionMigrateNormalForIoTV2StreamIT.java} | 2 +-
...IoTDBRegionMigrateOtherITForIoTV2StreamIT.java} | 2 +-
...rCrashWhenRemoveRemotePeerForIoTV2BatchIT.java} | 2 +-
...RegionMigrateDataNodeCrashForIoTV2BatchIT.java} | 2 +-
...alCrashWhenDeleteLocalPeerForIoTV2BatchIT.java} | 2 +-
...lCrashWhenRemoveRemotePeerForIoTV2BatchIT.java} | 2 +-
...CrashWhenRemoveRemotePeerForIoTV2StreamIT.java} | 2 +-
...egionMigrateDataNodeCrashForIoTV2StreamIT.java} | 2 +-
...lCrashWhenDeleteLocalPeerForIoTV2StreamIT.java} | 2 +-
...CrashWhenRemoveRemotePeerForIoTV2StreamIT.java} | 2 +-
...oTDBRegionMigrateClusterCrashIoTV2BatchIT.java} | 2 +-
...BRegionMigrateConfigNodeCrashIoTV2BatchIT.java} | 2 +-
...TDBRegionMigrateClusterCrashIoTV2StreamIT.java} | 2 +-
...RegionMigrateConfigNodeCrashIoTV2StreamIT.java} | 2 +-
.../apache/iotdb/db/it/IoTDBDuplicateTimeIT.java | 5 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 45 +
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 38 +
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 119 +
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 2 -
.../iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java | 2 +-
.../tablemodel/manual/basic/IoTDBPipeAlterIT.java | 7 +
.../manual/basic/IoTDBPipeDataSinkIT.java | 7 +
.../manual/basic/IoTDBPipeIsolationIT.java | 7 +
.../manual/basic/IoTDBPipeLifeCycleIT.java | 8 +
.../manual/basic/IoTDBPipeProtocolIT.java | 1 +
.../manual/basic/IoTDBPipeSwitchStatusIT.java | 8 +
.../tablemodel/manual/basic/IoTDBPipeSyntaxIT.java | 8 +
.../manual/basic/IoTDBTablePatternFormatIT.java | 7 +
.../manual/enhanced/IoTDBPipeAutoConflictIT.java | 1 +
.../manual/enhanced/IoTDBPipeAutoDropIT.java | 7 +
.../enhanced/IoTDBPipeConnectorParallelIT.java | 8 +
.../manual/enhanced/IoTDBPipeDoubleLivingIT.java | 7 +
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 8 +
.../manual/enhanced/IoTDBPipeMetaIT.java | 8 +
.../manual/enhanced/IoTDBPipeNullValueIT.java | 7 +
.../IoTDBPipeTypeConversionISessionIT.java | 8 +
.../manual/enhanced/IoTDBPipeTypeConversionIT.java | 7 +
.../treemodel/auto/basic/IoTDBPipeAlterIT.java | 7 +
.../auto/basic/IoTDBPipeConnectorParallelIT.java | 8 +
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 8 +
.../treemodel/auto/basic/IoTDBPipeLifeCycleIT.java | 8 +
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 1 +
.../treemodel/auto/basic/IoTDBPipeProtocolIT.java | 1 +
.../auto/basic/IoTDBPipeSwitchStatusIT.java | 8 +
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 8 +
.../auto/basic/IoTDBTreePatternFormatIT.java | 8 +
.../auto/enhanced/IoTDBPipeAutoConflictIT.java | 1 +
.../auto/enhanced/IoTDBPipeAutoDropIT.java | 7 +
.../enhanced/IoTDBPipeConditionalOperationsIT.java | 7 +
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 17 +-
.../treemodel/auto/enhanced/PipeNowFunctionIT.java | 7 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 74 +
.../relational/it/db/it/IoTDBRestartTableIT.java | 3 -
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 132 +
.../it/session/IoTDBSessionRelationalIT.java | 234 ++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 210 +-
.../regression/param/IoTDBTestParamTopicIT.java | 2 +-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 4 +-
.../apache/iotdb/tools/it/ExportSchemaTestIT.java | 4 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 36 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 4 +-
.../apache/iotdb/tools/it/ImportSchemaTestIT.java | 4 +-
.../src/test/resources/logback-test.xml | 2 +-
iotdb-client/cli/pom.xml | 4 +
.../org/apache/iotdb/tool/common/Constants.java | 30 +-
.../org/apache/iotdb/tool/common/OptionsUtil.java | 112 +
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 539 +--
.../subscription/AbstractSubscriptionTsFile.java | 74 +
.../tool/tsfile/subscription/CommonParam.java | 212 +
.../subscription/SubscriptionTableTsFile.java | 186 +
.../subscription/SubscriptionTreeTsFile.java | 183 +
iotdb-client/client-py/iotdb/Session.py | 61 +-
iotdb-client/client-py/iotdb/SessionPool.py | 4 +
iotdb-client/client-py/iotdb/table_session.py | 3 +
iotdb-client/client-py/iotdb/table_session_pool.py | 2 +
iotdb-client/jdbc/pom.xml | 55 +-
.../main/java/org/apache/iotdb/jdbc/Constant.java | 4 +-
...ata.java => IoTDBAbstractDatabaseMetadata.java} | 4330 +++++++++-----------
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 26 +-
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 3 -
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 3555 ++--------------
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 25 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 31 +-
.../IoTDBRelationalDatabaseMetadata.java | 447 ++
.../iotdb/rpc/subscription/config/TopicConfig.java | 7 +-
.../subscription/payload/poll/TabletsPayload.java | 4 +-
.../apache/iotdb/session/SessionConnection.java | 1019 ++---
.../consumer/ISubscriptionTablePullConsumer.java | 18 +
.../consumer/ISubscriptionTablePushConsumer.java | 18 +
.../consumer/ISubscriptionTreePullConsumer.java | 18 +
.../consumer/ISubscriptionTreePushConsumer.java | 18 +
.../base/AbstractSubscriptionConsumer.java | 24 +-
.../consumer/table/SubscriptionTableProvider.java | 18 +-
.../table/SubscriptionTablePullConsumer.java | 34 +-
.../table/SubscriptionTablePushConsumer.java | 36 +-
.../SubscriptionTablePushConsumerBuilder.java | 3 +-
.../consumer/tree/SubscriptionTreeProvider.java | 18 +-
.../tree/SubscriptionTreePullConsumer.java | 34 +-
.../tree/SubscriptionTreePushConsumer.java | 34 +-
.../apache/iotdb/session/util/CheckedSupplier.java | 32 -
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../pipe/payload/PipeDeleteLogicalViewPlan.java | 5 +-
.../pipe/payload/PipeDeleteTimeSeriesPlan.java | 5 +-
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 9 +
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ModelManager.java | 5 +
.../manager/load/balancer/RouteBalancer.java | 154 +-
.../iotdb/confignode/manager/node/NodeManager.java | 8 +
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 3 +
.../protocol/IoTDBConfigRegionConnector.java | 6 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 3 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 8 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 33 +-
.../iotdb/confignode/persistence/ModelInfo.java | 2 +-
.../partition/DatabasePartitionTable.java | 14 +-
.../schema/CNPhysicalPlanGenerator.java | 15 +-
...otParser.java => ConfigNodeSnapshotParser.java} | 24 +-
.../procedure/PartitionTableAutoCleaner.java | 3 +
.../procedure/impl/StateMachineProcedure.java | 16 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 2 +
.../impl/schema/AlterLogicalViewProcedure.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 44 +-
.../common/request/IConsensusRequest.java | 5 +
.../common/request/IndexedConsensusRequest.java | 8 +-
.../consensus/config/PipeConsensusConfig.java | 21 +-
.../consensus/iot/IoTConsensusServerImpl.java | 32 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 12 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 21 +-
...xManager.java => ReplicateProgressManager.java} | 8 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 71 +-
iotdb-core/datanode/pom.xml | 8 +
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 9 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 43 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 31 +-
.../db/consensus/DataRegionConsensusImpl.java | 4 +-
.../PipeDataRegionConnectorConstructor.java | 4 +
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 3 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 63 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 12 +-
.../agent/task/connection/PipeEventCollector.java | 11 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 9 +-
.../PipeRealtimePriorityBlockingQueue.java | 8 +-
.../processor/PipeProcessorSubtaskWorker.java | 6 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 13 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../evolvable/batch/PipeTabletEventBatch.java | 37 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 41 +-
.../batch/PipeTabletEventTsFileBatch.java | 11 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 3 +
.../connector/protocol/opcda/OpcDaConnector.java | 138 +
.../pipe/connector/protocol/opcda/OpcDaHeader.java | 200 +
.../protocol/opcda/OpcDaServerHandle.java | 390 ++
.../connector/protocol/opcua/OpcUaConnector.java | 50 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 2 +-
.../pipeconsensus/PipeConsensusAsyncConnector.java | 16 +-
.../pipeconsensus/PipeConsensusSyncConnector.java | 9 +-
.../PipeConsensusTabletInsertionEventHandler.java | 8 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 8 +-
.../PipeConsensusTransferBatchReqBuilder.java | 5 +-
.../async/IoTDBDataRegionAsyncConnector.java | 19 +-
.../handler/PipeTransferTrackableHandler.java | 33 +-
.../async/handler/PipeTransferTsFileHandler.java | 70 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
....java => ReplicateProgressDataNodeManager.java} | 36 +-
.../deletion/DeletionResourceManager.java | 4 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 5 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 64 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 27 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 7 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 56 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 26 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 54 +-
.../query/TsFileInsertionEventQueryParser.java | 70 +-
.../scan/TsFileInsertionEventScanParser.java | 38 +-
.../table/TsFileInsertionEventTableParser.java | 165 +-
...ileInsertionEventTableParserTabletIterator.java | 421 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 6 +
.../event/realtime/PipeRealtimeEventFactory.java | 81 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 27 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 8 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 139 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 21 +
.../listener/PipeInsertionDataNodeListener.java | 16 +-
.../iotdb/db/pipe/metric/PipeResourceMetrics.java | 28 +
.../processor/aggregate/AggregateProcessor.java | 18 +-
.../pipeconsensus/PipeConsensusProcessor.java | 43 +-
.../twostage/plugin/TwoStageCountProcessor.java | 14 +-
.../pipeconsensus/PipeConsensusReceiver.java | 338 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 20 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 2 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 137 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 65 +
.../db/protocol/mqtt/JSONPayloadFormatter.java | 9 +-
.../db/protocol/mqtt/LinePayloadFormatter.java | 257 ++
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 244 +-
.../org/apache/iotdb/db/protocol/mqtt/Message.java | 58 +-
.../iotdb/db/protocol/mqtt/PayloadFormatter.java | 6 +
.../iotdb/db/protocol/mqtt/TableMessage.java | 144 +
.../mqtt/{Message.java => TreeMessage.java} | 16 +-
.../db/protocol/rest/impl/PingApiServiceImpl.java | 4 +-
.../iotdb/db/protocol/session/SessionManager.java | 12 +
.../fragment/FragmentInstanceContext.java | 38 +
.../fragment/FragmentInstanceManager.java | 2 +
.../execution/fragment/QueryContext.java | 9 +
.../relational/aggregation/TableAggregator.java | 49 +-
.../queryengine/metric/QueryPlanCostMetricSet.java | 68 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 45 +-
.../db/queryengine/plan/analyze/Analyzer.java | 3 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 3 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 558 ++-
.../analyze/load/LoadTsFileTableSchemaCache.java | 11 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 226 -
.../load/LoadTsFileToTreeModelAnalyzer.java | 187 -
.../analyze/load/LoadTsFileTreeSchemaCache.java | 7 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 4 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 4 +-
.../plan/analyze/schema/SchemaValidator.java | 1 +
.../queryengine/plan/execution/QueryExecution.java | 14 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 19 +-
.../db/queryengine/plan/planner/IPlanner.java | 3 +-
.../plan/planner/LogicalPlanVisitor.java | 4 +-
.../queryengine/plan/planner/LogicalPlanner.java | 6 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 20 +-
.../plan/node/load/LoadSingleTsFileNode.java | 12 +-
.../plan/planner/plan/node/write/InsertNode.java | 1 +
.../plan/node/write/RelationalInsertRowNode.java | 5 +
.../plan/relational/analyzer/Analyzer.java | 3 +-
.../relational/analyzer/StatementAnalyzer.java | 27 +-
.../plan/relational/planner/RelationPlanner.java | 3 +-
.../relational/planner/TableLogicalPlanner.java | 16 +-
.../plan/relational/planner/TableModelPlanner.java | 32 +-
.../distribute/TableDistributedPlanner.java | 11 +-
...rrelatedGlobalAggregationWithoutProjection.java | 6 +-
.../rule/TransformExistsApplyToCorrelatedJoin.java | 2 +-
.../planner/optimizations/JoinUtils.java | 2 -
.../optimizations/LogicalOptimizeFactory.java | 1 -
.../optimizations/PlanNodeDecorrelator.java | 4 +-
.../optimizations/PushPredicateIntoTableScan.java | 6 +-
.../plan/relational/sql/ast/LoadTsFile.java | 14 +-
.../relational/sql/ast/WrappedInsertStatement.java | 78 +-
.../plan/relational/sql/parser/AstBuilder.java | 8 +-
.../plan/statement/crud/InsertBaseStatement.java | 50 +
.../crud/InsertMultiTabletsStatement.java | 11 +
.../plan/statement/crud/InsertRowStatement.java | 7 +
.../crud/InsertRowsOfOneDeviceStatement.java | 5 +
.../plan/statement/crud/InsertRowsStatement.java | 11 +
.../plan/statement/crud/InsertTabletStatement.java | 10 +
.../plan/statement/crud/LoadTsFileStatement.java | 18 +-
.../metadata/CountTimeSlotListStatement.java | 7 +
.../statement/metadata/GetRegionIdStatement.java | 7 +
.../metadata/GetSeriesSlotListStatement.java | 7 +
.../metadata/GetTimeSlotListStatement.java | 7 +
.../metadata/RemoveConfigNodeStatement.java | 9 +-
.../metadata/RemoveDataNodeStatement.java | 9 +-
.../statement/metadata/ShowClusterIdStatement.java | 7 +
.../statement/metadata/ShowClusterStatement.java | 9 +-
.../metadata/ShowConfigNodesStatement.java | 4 +-
.../statement/metadata/ShowDataNodesStatement.java | 4 +-
.../statement/metadata/ShowRegionStatement.java | 4 +-
.../metadata/model/ShowAINodesStatement.java | 7 +
.../metadata/region/ExtendRegionStatement.java | 9 +-
.../metadata/region/MigrateRegionStatement.java | 9 +-
.../region/ReconstructRegionStatement.java | 9 +-
.../metadata/region/RemoveRegionStatement.java | 9 +-
.../plan/statement/sys/KillQueryStatement.java | 9 +-
.../plan/statement/sys/ShowQueriesStatement.java | 9 +-
.../statement/sys/TestConnectionStatement.java | 3 +-
.../schemaregion/utils/ResourceByPathUtils.java | 146 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 66 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 22 +-
.../{RPCService.java => ExternalRPCService.java} | 6 +-
...viceMBean.java => ExternalRPCServiceMBean.java} | 2 +-
.../org/apache/iotdb/db/service/MQTTService.java | 2 +
.../iotdb/db/service/metrics/WritingMetrics.java | 29 +-
.../iotdb/db/storageengine/StorageEngine.java | 31 +-
.../db/storageengine/dataregion/DataRegion.java | 30 +-
.../performer/impl/FastCompactionPerformer.java | 4 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 7 +-
.../executor/fast/SeriesCompactionExecutor.java | 20 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 4 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 6 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 30 +-
.../utils/writer/AbstractCompactionWriter.java | 5 +-
.../writer/AbstractCrossCompactionWriter.java | 7 +-
.../writer/AbstractInnerCompactionWriter.java | 1 +
.../utils/writer/FastCrossCompactionWriter.java | 6 +
.../utils/writer/FastInnerCompactionWriter.java | 6 +
.../writer/ReadPointCrossCompactionWriter.java | 1 +
.../compaction/repair/RepairDataFileScanUtil.java | 56 +-
.../estimator/AbstractCompactionEstimator.java | 9 +-
.../selector/impl/SettleSelectorImpl.java | 24 +-
.../selector/utils/TsFileResourceCandidate.java | 13 +-
.../dataregion/flush/MemTableFlushTask.java | 16 +-
.../dataregion/memtable/AbstractMemTable.java | 203 +-
.../memtable/AlignedReadOnlyMemChunk.java | 588 ++-
.../memtable/AlignedWritableMemChunk.java | 761 +++-
.../memtable/AlignedWritableMemChunkGroup.java | 36 +-
.../dataregion/memtable/IMemTable.java | 10 +-
.../dataregion/memtable/IWritableMemChunk.java | 56 +-
.../memtable/IWritableMemChunkGroup.java | 11 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 274 +-
.../dataregion/memtable/TsFileProcessor.java | 106 +-
.../dataregion/memtable/WritableMemChunk.java | 603 ++-
.../dataregion/memtable/WritableMemChunkGroup.java | 50 +-
.../dataregion/modification/ModificationFile.java | 16 +-
.../filescan/impl/MemAlignedChunkHandleImpl.java | 21 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 259 +-
.../read/reader/chunk/MemAlignedPageReader.java | 137 +-
.../read/reader/chunk/MemChunkReader.java | 139 +-
.../read/reader/chunk/MemPageReader.java | 129 +-
.../reader/chunk/metadata/AlignedPageMetadata.java | 74 +
.../read/reader/chunk/metadata/PageMetadata.java | 90 +
.../dataregion/tsfile/TsFileResource.java | 84 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 23 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 9 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 5 +-
.../utils/TsFileDeviceStartEndTimeIterator.java | 6 +-
.../dataregion/utils/TsFileResourceUtils.java | 30 +-
.../storageengine/dataregion/wal/io/WALReader.java | 2 +-
.../wal/recover/file/TsFilePlanRedoer.java | 9 +-
.../file/UnsealedTsFileRecoverPerformer.java | 10 +-
.../load/config/LoadTsFileConfigurator.java | 24 -
.../load/splitter/AlignedChunkData.java | 16 +-
.../splitter/BatchedAlignedValueChunkData.java | 8 +-
.../load/splitter/NonAlignedChunkData.java | 8 +-
.../load/splitter/TsFileSplitter.java | 7 +
.../broker/SubscriptionPrefetchingQueue.java | 13 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 14 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 14 +-
.../db/subscription/event/SubscriptionEvent.java | 4 +-
.../event/batch/SubscriptionPipeEventBatch.java | 2 +-
.../event/batch/SubscriptionPipeEventBatches.java | 2 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 56 +-
.../SubscriptionPipeTabletIterationSnapshot.java | 78 +
.../batch/SubscriptionPipeTsFileEventBatch.java | 2 +-
.../event/cache/SubscriptionPollResponseCache.java | 11 +
.../event/pipe/SubscriptionPipeEmptyEvent.java | 2 +-
.../event/pipe/SubscriptionPipeEvents.java | 2 +-
.../pipe/SubscriptionPipeTabletBatchEvents.java | 36 +-
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 4 +-
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 2 +-
.../response/SubscriptionEventTsFileResponse.java | 7 +-
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 6 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 10 +-
.../iotdb/db/tools/utils/TsFileValidationScan.java | 10 +-
.../TsFileOverlapValidationAndRepairTool.java | 8 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 24 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 17 +
.../iotdb/db/utils/TimestampPrecisionUtils.java | 16 +-
.../db/utils/datastructure/AlignedTVList.java | 457 ++-
.../db/utils/datastructure/BackAlignedTVList.java | 66 +-
.../db/utils/datastructure/BackBinaryTVList.java | 72 +-
.../db/utils/datastructure/BackBooleanTVList.java | 71 +-
.../db/utils/datastructure/BackDoubleTVList.java | 71 +-
.../db/utils/datastructure/BackFloatTVList.java | 71 +-
.../db/utils/datastructure/BackIntTVList.java | 72 +-
.../db/utils/datastructure/BackLongTVList.java | 71 +-
.../iotdb/db/utils/datastructure/BackwardSort.java | 66 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 152 +-
.../db/utils/datastructure/BooleanTVList.java | 99 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 100 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 100 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 99 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 99 +-
.../MergeSortAlignedTVListIterator.java | 242 ++
.../datastructure/MergeSortTvListIterator.java | 162 +
.../PageColumnAccessInfo.java} | 43 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 34 +-
.../db/utils/datastructure/QuickBinaryTVList.java | 34 +-
.../db/utils/datastructure/QuickBooleanTVList.java | 31 +-
.../db/utils/datastructure/QuickDoubleTVList.java | 31 +-
.../db/utils/datastructure/QuickFloatTVList.java | 31 +-
.../db/utils/datastructure/QuickIntTVList.java | 37 +-
.../db/utils/datastructure/QuickLongTVList.java | 31 +-
.../iotdb/db/utils/datastructure/QuickSort.java | 28 +-
.../iotdb/db/utils/datastructure/TVList.java | 417 +-
.../db/utils/datastructure/TimAlignedTVList.java | 109 +-
.../db/utils/datastructure/TimBinaryTVList.java | 113 +-
.../db/utils/datastructure/TimBooleanTVList.java | 111 +-
.../db/utils/datastructure/TimDoubleTVList.java | 111 +-
.../db/utils/datastructure/TimFloatTVList.java | 112 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 112 +-
.../db/utils/datastructure/TimLongTVList.java | 111 +-
.../iotdb/db/utils/datastructure/TimSort.java | 105 +-
....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 1 +
.../org/apache/iotdb/db/auth/entity/UserTest.java | 4 +-
.../db/protocol/mqtt/JSONPayloadFormatterTest.java | 8 +-
.../db/protocol/mqtt/LinePayloadFormatterTest.java | 91 +
.../db/protocol/rest/IoTDBRestServiceTest.java | 6 +-
.../plan/relational/analyzer/AnalyzerTest.java | 7 +-
.../storageengine/dataregion/DataRegionTest.java | 6 +-
.../compaction/CompactionDataTypeNotMatchTest.java | 19 +-
.../FastCompactionPerformerWithEmptyPageTest.java | 5 +-
.../FastInnerCompactionPerformerTest.java | 134 +-
.../ReadPointCompactionPerformerTest.java | 134 +-
.../TsFileValidationCorrectnessTests.java | 14 +-
...eCompactionWithFastPerformerValidationTest.java | 14 +-
...actionWithReadPointPerformerValidationTest.java | 14 +-
.../InsertionCrossSpaceCompactionRecoverTest.java | 4 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 4 +-
.../cross/RewriteCompactionFileSelectorTest.java | 6 +-
.../compaction/utils/CompactionCheckerUtils.java | 11 +-
.../memtable/MemChunkDeserializeTest.java | 332 ++
.../dataregion/memtable/PrimitiveMemTableTest.java | 41 +-
.../dataregion/memtable/TsFileProcessorTest.java | 443 +-
.../read/control/FileReaderManagerTest.java | 5 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 32 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 138 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 260 +-
.../read/reader/chunk/MemPageReaderTest.java | 12 +-
.../dataregion/tsfile/TsFileResourceTest.java | 12 +-
.../wal/recover/WALRecoverManagerTest.java | 21 +-
.../file/SealedTsFileRecoverPerformerTest.java | 33 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 18 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 21 +-
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 14 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 -
.../db/utils/datastructure/AlignedTVListTest.java | 20 +-
.../db/utils/datastructure/BinaryTVListTest.java | 30 -
.../datanode/src/test/resources/logback-test.xml | 2 +-
.../conf/iotdb-system.properties.template | 41 +-
.../src/assembly/resources/sbin/health_check.bat | 2 +-
.../commons/auth/authorizer/OpenIdAuthorizer.java | 6 +-
.../org/apache/iotdb/commons/auth/entity/User.java | 8 +-
.../async/AsyncPipeDataTransferServiceClient.java | 14 +
.../apache/iotdb/commons/conf/CommonConfig.java | 47 +-
.../iotdb/commons/conf/CommonDescriptor.java | 19 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../commons/partition/DataPartitionTable.java | 10 +-
.../commons/partition/SeriesPartitionTable.java | 20 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 5 +
.../OpcDaConnector.java} | 10 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 52 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 21 +-
.../config/constant/PipeConnectorConstant.java | 12 +-
.../pipe/connector/client/IoTDBClientManager.java | 6 +-
.../connector/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../connector/protocol/IoTDBAirGapConnector.java | 21 +-
.../pipe/connector/protocol/IoTDBConnector.java | 12 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 17 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 8 +
.../db/relational/grammar/sql/RelationalSql.g4 | 5 +-
.../thrift-commons/src/main/thrift/common.thrift | 1 +
.../src/main/thrift/pipeconsensus.thrift | 5 +-
pom.xml | 12 +-
485 files changed, 17273 insertions(+), 12349 deletions(-)
rename
integration-test/src/test/java/org/apache/iotdb/cli/it/{AbstractScript.java =>
AbstractScriptIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBAutoRegionGroupExtensionIT2.java
=> IoTDBAutoRegionGroupExtension2IT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBPartitionTableAutoCleanTest.java
=> IoTDBPartitionTableAutoCleanIT.java} (99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/batch/{IoTDBRegionMigrateNormalITForIoTV2Batch.java
=> IoTDBRegionMigrateNormalITForIoTV2BatchIT.java} (96%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/batch/{IoTDBRegionMigrateOtherITForIoTV2Batch.java
=> IoTDBRegionMigrateOtherForIoTV2BatchIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/stream/{IoTDBRegionMigrateNormalITForIoTV2Stream.java
=> IoTDBRegionMigrateNormalForIoTV2StreamIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/stream/{IoTDBRegionMigrateOtherITForIoTV2Stream.java
=> IoTDBRegionMigrateOtherITForIoTV2StreamIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2Batch.java
=> IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateDataNodeCrashForIoTV2Batch.java
=> IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2Batch.java
=> IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2Batch.java
=> IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2Stream.java
=>
IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateDataNodeCrashForIoTV2Stream.java
=> IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2Stream.java
=> IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2Stream.java
=> IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/batch/{IoTDBRegionMigrateClusterCrashIoTV2Batch.java
=> IoTDBRegionMigrateClusterCrashIoTV2BatchIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/batch/{IoTDBRegionMigrateConfigNodeCrashIoTV2Batch.java
=> IoTDBRegionMigrateConfigNodeCrashIoTV2BatchIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/stream/{IoTDBRegionMigrateClusterCrashIoTV2Stream.java
=> IoTDBRegionMigrateClusterCrashIoTV2StreamIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/stream/{IoTDBRegionMigrateConfigNodeCrashIoTV2Stream.java
=> IoTDBRegionMigrateConfigNodeCrashIoTV2StreamIT.java} (98%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/mqtt/IoTDBMQTTServiceIT.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/AbstractSubscriptionTsFile.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/CommonParam.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/SubscriptionTableTsFile.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/SubscriptionTreeTsFile.java
copy
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/{IoTDBDatabaseMetadata.java
=> IoTDBAbstractDatabaseMetadata.java} (61%)
create mode 100644
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/relational/IoTDBRelationalDatabaseMetadata.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/CheckedSupplier.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/{ConfignodeSnapshotParser.java
=> ConfigNodeSnapshotParser.java} (91%)
rename
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/{ProgressIndexManager.java
=> ReplicateProgressManager.java} (81%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaConnector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaHeader.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaServerHandle.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/{ProgressIndexDataNodeManager.java
=> ReplicateProgressDataNodeManager.java} (78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/LinePayloadFormatter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/TableMessage.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/{Message.java
=> TreeMessage.java} (87%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileToTableModelAnalyzer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileToTreeModelAnalyzer.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/{RPCService.java
=> ExternalRPCService.java} (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/{RPCServiceMBean.java
=> ExternalRPCServiceMBean.java} (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/AlignedPageMetadata.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/PageMetadata.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletIterationSnapshot.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortAlignedTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortTvListIterator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/{SetThreadName.java
=> datastructure/PageColumnAccessInfo.java} (57%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/mqtt/LinePayloadFormatterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemChunkDeserializeTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/{opcua/OpcUaConnector.java
=> opcda/OpcDaConnector.java} (86%)
