This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch share_mod_file
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 65172b4b2f9 Merge branch 'master' into share_mod_file
add a11401b494f add repair data for table model (#14705)
add c3df7d54496 Renaming the IT Methods of the IoTDB REST Service Table
Model (#14681)
add 6cb9035e8f6 Pipe IT: Added flush for assertData on targetEnv to avoid
IoTV2 batch mode lead to large delay (#14707)
add 42878058f11 [RATISCONSENSUS] Bump ratis version to 3.1.3 (#14709)
add 6961e2154a7 Fix NPE when concurrent closing mod files (#14708)
add 8e7605f80db Fix cache invalidation failure and add retry (#14711)
add 44e9725ab94 Publish build scans to develocity.apache.org (#14701)
add c3baa7a4978 Subscription: fix `hasNext` method in tablet batch to
support multiple tsfile in the same batch (#14715)
add 6036cabd9dc Implemented access control for
pipe/subscription/table/database
add 3072ae5a668 Implement distinct in AggFunction
add 49a91ecd348 Add more user-friendly error messages for the last and
last_by aggregation
add 141b7ba634c Extend Region & Remove Region & Reconstruct Region (#14634)
add a011b013711 Pipe: Unify the case of the table model database and fix
the incorrect use of iterators in Load File (#14718)
add 75dda9fb0ef Pipe: Fixed the bug that alter logical view statement uses
a common partial path (#14713)
add bc5fdaed8d9 Bump TsFile version to 2.0.0-250118-SNAPSHOT
add 670b45675e0 Pipe: Fix HA issues caused by exceptions not handled in
handshake (IoTDBAirGapConnector / IoTDBSyncClientManager) (#14706)
add fea2e4fc8f8 [Table Model Subquery] Support uncorrelated quantified
comparison
add 263443dcb53 The time range of device in resource file may be larger
than the actual time range in tsfile (#14712)
add 95a70b1ec03 Fix reload4j vulnerability issue (#14740)
add 41a49e7c1e6 Refactor procedure framework (simplified
StateMachineProcedure, and some other things) (#14683)
add 9f8bf85a212 Fix memory leak while inserting using sql
add 3cfe818a51b Fix mqtt logger issue (#14742)
add 3bdffe14d02 Fix mqtt logger issue (#14744)
add fcb3fac14c5 Added permission check for auto create table / add column
& auto create database / insert in tsFile load
add cac80f031c0 Fixed the bug that measurement is not replaced to null for
logical view's partial insert (#14743)
add 2448945529d Fix createView NPE issue when region migration #14746
add 8b6311bd042 Reduced the log of table cache update
add ace3d5baefb Settle task was selected without mods and ttl (#14731)
add 0f799c6b58f Subscription: intro table model subscription session and
consumer (#14406)
add 34914932924 Correct the Blob data cast error msg
add 9be5eeb18c3 Fix delete data TsFileProcessor NPE (#14748)
add 765cbb213b0 Extract "merge" method for SearchNode (#14736)
add ddd580d17ed Fix format IT
add 42531c3975f Bump jetty version to 9.4.57.v20241219
add 1cfd139cd23 Add optimizers for distinct in AggFunction
add a681582d6c8 Fix wrong deviceId after
PartialPath.concatAsMeasurementPath (#14750)
add 79b08072fd6 Fix region reconstruction IT (#14753)
add cb4c05c0319 Region group status refactor (#14738)
add 7f3b281f7d3 [remove datanode] Add Remove DataNode SQL (#14678)
add 3369e7a202e Let the DataPartitionTable be automatically cleanable
(#14737)
add 04810e27cc8 Fix predicate pushdown when dealing with ProjectNode
(#14754)
add 8c62821f1ad [Daily IT]: Daily IT adds a single region task (#14659)
add e56b34f3535 fix mods file metrics & fix the issue of missing mods with
concurrent deletion and compaction (#14765)
add 7af1b52dbcb Implemented TableDeviceSchemaCache#getLastEntries for query
add 93e83c63fbd Pipe: incorporate batch data into
TsFileInsertionEventScanParser memory control & Subscription: close data
container in tsfile event & bind memory block for tablet response & generate
empty tablet as initial response & offer subsequent tablet response before ack
& expose prefetch and backdoor configs & best-effort disorder control (#14752)
add 5933818eec7 Delete the adjustment operation of TCP port (#14770)
add 52da69813b0 Fixed the NPE of TableDeviceLastEntry
add be3e043d571 Merge branch 'master' into share_mod_file
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 2 +-
.github/workflows/cluster-it-1c1d1a.yml | 2 +-
.github/workflows/cluster-it-1c3d.yml | 2 +-
.github/workflows/compile-check.yml | 2 +-
.github/workflows/daily-it.yml | 38 +-
.github/workflows/daily-ut.yml | 2 +-
.github/workflows/dependency-check.yml | 2 +-
.github/workflows/pipe-it-2cluster.yml | 2 +-
.github/workflows/sonar-codecov.yml | 2 +-
.github/workflows/table-cluster-it-1c1d.yml | 2 +-
.github/workflows/table-cluster-it-1c3d.yml | 2 +-
.github/workflows/unit-test.yml | 2 +-
.github/workflows/vulnerability-check.yml | 2 +-
.mvn/develocity.xml | 3 +-
.mvn/extensions.xml | 4 +-
.../apache/iotdb/SubscriptionSessionExample.java | 35 +-
.../TableModelSubscriptionSessionExample.java | 173 ++++
integration-test/pom.xml | 2 +
.../java/org/apache/iotdb/it/env/EnvFactory.java | 5 +
.../iotdb/it/env/cluster/ClusterConstant.java | 2 +
.../it/env/cluster/config/MppCommonConfig.java | 12 +
.../it/env/cluster/config/MppDataNodeConfig.java | 7 +
.../env/cluster/config/MppSharedCommonConfig.java | 14 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 44 +
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 5 +
.../it/env/cluster/node/AbstractNodeWrapper.java | 12 +
.../it/env/cluster/node/ConfigNodeWrapper.java | 5 +
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 11 +
.../it/env/remote/config/RemoteCommonConfig.java | 10 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 5 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 7 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 2 +
.../IoTDBPartitionTableAutoCleanTest.java | 135 ++++
...ionMigrateDataNodeCrashITFrameworkForIoTV1.java | 2 +-
...ionMigrateDataNodeCrashITFrameworkForIoTV2.java | 2 +-
...oTDBRegionOperationReliabilityITFramework.java} | 174 ++--
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 157 ++++
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 149 ++++
.../IoTDBRegionMigrateNormalITForIoTV2Batch.java | 4 +-
.../IoTDBRegionMigrateOtherITForIoTV2Batch.java | 4 +-
.../IoTDBRegionMigrateNormalITForIoTV2Stream.java | 4 +-
.../IoTDBRegionMigrateOtherITForIoTV2Stream.java | 4 +-
.../IoTDBRegionMigrateDataNodeCrashForIoTV1IT.java | 4 +-
...TDBRegionMigrateDataNodeCrashForIoTV2Batch.java | 4 +-
...DBRegionMigrateDataNodeCrashForIoTV2Stream.java | 4 +-
.../IoTDBRegionMigrateClusterCrashIoTV1IT.java | 4 +-
.../IoTDBRegionMigrateConfigNodeCrashIoTV1IT.java | 4 +-
.../IoTDBRegionMigrateClusterCrashIoTV2Batch.java | 4 +-
...oTDBRegionMigrateConfigNodeCrashIoTV2Batch.java | 4 +-
.../IoTDBRegionMigrateClusterCrashIoTV2Stream.java | 4 +-
...TDBRegionMigrateConfigNodeCrashIoTV2Stream.java | 4 +-
.../IoTDBRemoveDataNodeITFramework.java | 113 ++-
.../IoTDBRemoveDataNodeNormalIT.java | 25 +-
.../confignode/it/removedatanode/SQLModel.java | 9 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 3 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 181 ++++-
.../pipe/it/autocreate/IoTDBPipeAutoDropIT.java | 10 +-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 98 +++
.../pipe/it/tablemodel/IoTDBPipeAutoDropIT.java | 10 +-
.../pipe/it/tablemodel/IoTDBPipeClusterIT.java | 65 ++
.../pipe/it/tablemodel/IoTDBPipeDataSinkIT.java | 2 +-
.../iotdb/pipe/it/tablemodel/TableModelUtils.java | 15 +
.../relational/it/db/it/IoTDBDeletionTableIT.java | 283 ++++++-
.../udf/IoTDBUserDefinedAggregateFunctionIT.java | 53 +-
.../scalar/IoTDBFormatFunctionTableIT.java | 18 +-
.../IoTDBTableAggregationFunctionDistinctIT.java | 374 +++++++++
.../it/query/recent/IoTDBTableAggregationIT.java | 893 ++++++++++++++++++++-
.../IoTDBUncorrelatedQuantifiedComparisonIT.java | 674 ++++++++++++++++
.../it/rest/it/IoTDBRestServiceCaseWhenThenIT.java | 7 +-
.../it/rest/it/IoTDBRestServiceFlushQueryIT.java | 6 +-
.../relational/it/rest/it/IoTDBRestServiceIT.java | 3 +-
...IT.java => IoTDBRestServiceInsertValuesIT.java} | 20 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 23 +
.../subscription/it/AbstractSubscriptionIT.java | 2 +-
.../it/cluster/IoTDBSubscriptionRestartIT.java | 34 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 16 +-
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 10 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 44 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 42 +-
.../it/local/IoTDBSubscriptionDataTypeIT.java | 10 +-
.../it/local/IoTDBSubscriptionIdempotentIT.java | 24 +-
.../it/local/IoTDBSubscriptionTopicIT.java | 10 +-
.../it/triple/AbstractSubscriptionTripleIT.java | 2 +-
.../it/triple/IoTDBSubscriptionSharingIT.java | 32 +-
.../AbstractSubscriptionRegressionIT.java | 26 +-
.../IoTDBDefaultPullConsumerDataSetIT.java | 4 +-
.../IoTDBDefaultTsfilePushConsumerIT.java | 6 +-
.../IoTDBRootDatasetPushConsumerIT.java | 6 +-
.../IoTDBRootPullConsumeTsfileIT.java | 6 +-
...merPullConsumerWith1TopicShareProcessMixIT.java | 12 +-
.../param/IoTDBTestParamPullConsumerIT.java | 93 ++-
.../param/IoTDBTestParamPushConsumerIT.java | 47 +-
.../param/IoTDBTestParamSubscriptionSessionIT.java | 12 +-
.../regression/param/IoTDBTestParamTopicIT.java | 6 +-
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 6 +-
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 6 +-
.../format/IoTDBDBDataSetPullConsumerIT.java | 6 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 6 +-
.../IoTDBAllTsDatasetPullConsumerIT.java | 4 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 6 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 6 +-
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 4 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 6 +-
.../IoTDBTimeTsDatasetPullConsumerIT.java | 4 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 6 +-
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 4 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 6 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 6 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 6 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 12 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 4 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 4 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 4 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 6 +-
.../IoTDBDBPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 6 +-
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 4 +-
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 4 +-
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 6 +-
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 6 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 6 +-
.../IoTDBTSPatternPullConsumerDataSetIT.java | 4 +-
.../time/IoTDBAllPullConsumerDataSetIT.java | 4 +-
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 4 +-
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 4 +-
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 4 +-
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 4 +-
.../format/IoTDBTestPushConsumeDataSetIT.java | 6 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 6 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 6 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 6 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 6 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 6 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 6 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 6 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 6 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 6 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 6 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 6 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 6 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 6 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 6 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 6 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 10 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 10 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 26 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 6 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 6 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 6 +-
.../IoTDBDBPatternDatasetPushConsumerIT.java | 6 +-
.../IoTDBDBPatternTsfilePushConsumerIT.java | 6 +-
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 6 +-
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 6 +-
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 6 +-
.../IoTDBRootPatternDatasetPushConsumerIT.java | 6 +-
.../IoTDBTSPatternDatasetPushConsumerIT.java | 6 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 6 +-
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 6 +-
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 6 +-
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 6 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 6 +-
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 6 +-
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 6 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 6 +-
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 4 +-
.../regression/topic/IoTDBTestTopicNameIT.java | 4 +-
.../regression/user/IoTDBOtherUserConsumerIT.java | 6 +-
.../java/org/apache/iotdb/util/MagicUtils.java | 61 ++
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 1 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 22 +
.../subscription/payload/poll/TabletsPayload.java | 11 +-
.../subscription/AbstractSubscriptionSession.java | 219 +++++
.../subscription/ISubscriptionTableSession.java | 177 ++++
.../subscription/ISubscriptionTreeSession.java | 177 ++++
.../session/subscription/SubscriptionSession.java | 337 --------
.../SubscriptionSessionConnection.java | 26 +-
.../subscription/SubscriptionSessionWrapper.java | 72 ++
.../subscription/SubscriptionTableSession.java | 113 +++
.../SubscriptionTableSessionBuilder.java | 66 ++
.../subscription/SubscriptionTreeSession.java | 180 +++++
.../SubscriptionTreeSessionBuilder.java | 63 ++
.../consumer/ISubscriptionTablePullConsumer.java | 181 +++++
.../consumer/ISubscriptionTablePushConsumer.java | 86 ++
.../consumer/ISubscriptionTreePullConsumer.java | 181 +++++
.../consumer/ISubscriptionTreePushConsumer.java | 86 ++
.../AbstractSubscriptionConsumer.java} | 170 +---
.../base/AbstractSubscriptionConsumerBuilder.java | 150 ++++
.../AbstractSubscriptionProvider.java} | 47 +-
.../AbstractSubscriptionProviders.java} | 58 +-
.../AbstractSubscriptionPullConsumer.java} | 155 +---
.../AbstractSubscriptionPullConsumerBuilder.java | 122 +++
.../AbstractSubscriptionPushConsumer.java} | 147 +---
.../AbstractSubscriptionPushConsumerBuilder.java | 139 ++++
.../SubscriptionExecutorServiceManager.java | 2 +-
.../consumer/table/SubscriptionTableProvider.java | 49 ++
.../table/SubscriptionTablePullConsumer.java | 152 ++++
.../SubscriptionTablePullConsumerBuilder.java | 125 +++
.../table/SubscriptionTablePushConsumer.java | 95 +++
.../SubscriptionTablePushConsumerBuilder.java | 138 ++++
.../consumer/tree/SubscriptionTreeProvider.java | 49 ++
.../tree/SubscriptionTreePullConsumer.java | 317 ++++++++
.../tree/SubscriptionTreePullConsumerBuilder.java | 124 +++
.../tree/SubscriptionTreePushConsumer.java | 290 +++++++
.../tree/SubscriptionTreePushConsumerBuilder.java | 139 ++++
.../session/subscription/model/Subscription.java | 3 +-
.../iotdb/session/subscription/model/Topic.java | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 21 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 12 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 9 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../partition/AutoCleanPartitionTablePlan.java | 99 +++
.../iotdb/confignode/manager/ConfigManager.java | 27 +
.../apache/iotdb/confignode/manager/IManager.java | 9 +
.../iotdb/confignode/manager/ProcedureManager.java | 467 ++++++++---
.../iotdb/confignode/manager/TTLManager.java | 11 +
.../confignode/manager/load/cache/LoadCache.java | 13 +-
.../load/cache/region/RegionGroupCache.java | 39 +-
.../manager/partition/PartitionManager.java | 13 +-
.../manager/partition/RegionGroupStatus.java | 25 +-
.../iotdb/confignode/persistence/TTLInfo.java | 16 +
.../persistence/executor/ConfigPlanExecutor.java | 3 +
.../partition/DatabasePartitionTable.java | 10 +
.../persistence/partition/PartitionInfo.java | 19 +
.../persistence/schema/ClusterSchemaInfo.java | 6 +-
.../confignode/procedure/InternalProcedure.java | 5 -
.../procedure/PartitionTableAutoCleaner.java | 81 ++
.../iotdb/confignode/procedure/Procedure.java | 78 --
.../confignode/procedure/ProcedureExecutor.java | 115 +--
.../procedure/env/ConfigNodeProcedureEnv.java | 19 +-
.../procedure/env/RegionMaintainHandler.java | 13 +-
.../procedure/impl/StateMachineProcedure.java | 181 ++---
.../impl/region/AddRegionPeerProcedure.java | 84 +-
.../impl/region/ReconstructRegionProcedure.java | 209 +++++
.../impl/region/RegionMigrateProcedure.java | 39 +-
.../impl/region/RegionOperationProcedure.java} | 33 +-
.../impl/region/RemoveRegionPeerProcedure.java | 52 +-
.../procedure/impl/sync/StartPipeProcedure.java | 6 -
...itionState.java => ReconstructRegionState.java} | 8 +-
.../procedure/store/ProcedureFactory.java | 5 +
.../confignode/procedure/store/ProcedureType.java | 5 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 18 +
.../request/ConfigPhysicalPlanSerDeTest.java | 19 +
.../confignode/manager/load/LoadManagerTest.java | 12 +-
.../manager/load/cache/RegionGroupCacheTest.java | 132 +--
.../confignode/procedure/entity/IncProcedure.java | 5 -
.../confignode/procedure/entity/NoopProcedure.java | 5 -
.../procedure/entity/SimpleLockProcedure.java | 5 -
.../procedure/entity/SleepProcedure.java | 5 -
.../procedure/entity/StuckProcedure.java | 5 -
.../apache/iotdb/consensus/ratis/RatisClient.java | 6 +-
.../apache/iotdb/consensus/ratis/utils/Utils.java | 1 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 20 +-
.../dataregion/DataRegionStateMachine.java | 144 +---
.../client/IoTDBDataNodeAsyncClientManager.java | 2 +-
.../protocol/writeback/WriteBackConnector.java | 4 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 10 +-
.../scan/TsFileInsertionEventScanParser.java | 19 +
.../schemachange/RenameDatabaseProcessor.java | 9 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 48 ++
.../iotdb/db/protocol/client/ConfigNodeClient.java | 21 +
.../iotdb/db/protocol/session/ClientSession.java | 20 +-
.../iotdb/db/protocol/session/IClientSession.java | 1 +
.../db/protocol/session/InternalClientSession.java | 5 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 40 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 1 -
.../thrift/impl/DataNodeRegionManager.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 11 +-
.../source/relational/MarkDistinctOperator.java | 170 ++++
.../relational/aggregation/AccumulatorFactory.java | 247 +++++-
.../relational/aggregation/AggregationMask.java | 204 +++++
.../relational/aggregation/AvgAccumulator.java | 122 ++-
.../relational/aggregation/CountAccumulator.java | 22 +-
...IfAccumulator.java => CountAllAccumulator.java} | 48 +-
.../relational/aggregation/CountIfAccumulator.java | 22 +-
.../relational/aggregation/ExtremeAccumulator.java | 94 ++-
.../relational/aggregation/FirstAccumulator.java | 158 +++-
.../relational/aggregation/FirstByAccumulator.java | 164 +++-
.../aggregation/FirstByDescAccumulator.java | 132 ++-
.../aggregation/FirstDescAccumulator.java | 126 ++-
.../relational/aggregation/LastAccumulator.java | 140 +++-
.../relational/aggregation/LastByAccumulator.java | 146 +++-
.../aggregation/LastByDescAccumulator.java | 150 +++-
.../aggregation/LastDescAccumulator.java | 144 +++-
.../MaskedRecordIterator.java} | 24 +-
.../relational/aggregation/MaxAccumulator.java | 140 +++-
.../relational/aggregation/MinAccumulator.java | 140 +++-
.../relational/aggregation/SumAccumulator.java | 114 ++-
.../relational/aggregation/TableAccumulator.java | 2 +-
.../relational/aggregation/TableAggregator.java | 9 +-
.../aggregation/TableMaxMinByBaseAccumulator.java | 146 +++-
.../aggregation/TableModeAccumulator.java | 192 +++--
.../aggregation/TableVarianceAccumulator.java | 158 +++-
.../UserDefinedAggregateFunctionAccumulator.java | 8 +-
.../aggregation/grouped/GroupedAccumulator.java | 4 +-
.../aggregation/grouped/GroupedAggregator.java | 6 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 119 ++-
.../grouped/GroupedCountAccumulator.java | 22 +-
.../grouped/GroupedCountIfAccumulator.java | 22 +-
.../grouped/GroupedExtremeAccumulator.java | 95 ++-
.../grouped/GroupedFirstAccumulator.java | 153 +++-
.../grouped/GroupedFirstByAccumulator.java | 191 +++--
.../grouped/GroupedLastAccumulator.java | 133 ++-
.../grouped/GroupedLastByAccumulator.java | 150 +++-
.../aggregation/grouped/GroupedMaxAccumulator.java | 141 +++-
.../grouped/GroupedMaxMinByBaseAccumulator.java | 147 +++-
.../aggregation/grouped/GroupedMinAccumulator.java | 141 +++-
.../grouped/GroupedModeAccumulator.java | 246 ++++--
.../aggregation/grouped/GroupedSumAccumulator.java | 111 ++-
.../GroupedUserDefinedAggregateAccumulator.java | 14 +-
.../grouped/GroupedVarianceAccumulator.java | 159 +++-
.../aggregation/grouped/hash/GroupByHash.java | 2 +
.../aggregation/grouped/hash/MarkDistinctHash.java | 90 +++
.../relational/ColumnTransformerBuilder.java | 6 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 8 +-
.../load/LoadTsFileToTableModelAnalyzer.java | 9 +-
.../queryengine/plan/execution/QueryExecution.java | 2 -
.../execution/config/TableConfigTaskVisitor.java | 152 +++-
.../execution/config/TreeConfigTaskVisitor.java | 36 +-
.../config/executor/ClusterConfigTaskExecutor.java | 151 +++-
.../config/executor/IConfigTaskExecutor.java | 18 +-
...rateRegionTask.java => RemoveDataNodeTask.java} | 12 +-
.../ExtendRegionTask.java} | 14 +-
.../metadata/{ => region}/MigrateRegionTask.java | 4 +-
.../ReconstructRegionTask.java} | 16 +-
.../RemoveRegionTask.java} | 14 +-
.../metadata/relational/ShowTablesDetailsTask.java | 47 +-
.../config/metadata/relational/ShowTablesTask.java | 35 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 41 +-
.../plan/planner/TableOperatorGenerator.java | 54 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 41 +-
.../plan/planner/plan/node/PlanNodeType.java | 4 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../node/metadata/write/AlterTimeSeriesNode.java | 9 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 13 +
.../plan/node/pipe/PipeEnrichedInsertNode.java | 5 +
.../ContinuousSameSearchIndexSeparatorNode.java | 6 +
.../planner/plan/node/write/DeleteDataNode.java | 36 +
.../plan/node/write/InsertMultiTabletsNode.java | 5 +
.../plan/planner/plan/node/write/InsertNode.java | 21 +
.../planner/plan/node/write/InsertRowNode.java | 12 +
.../planner/plan/node/write/InsertRowsNode.java | 15 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 5 +
.../planner/plan/node/write/InsertTabletNode.java | 11 +
.../plan/node/write/RelationalDeleteDataNode.java | 23 +-
.../plan/planner/plan/node/write/SearchNode.java | 4 +
.../relational/analyzer/StatementAnalyzer.java | 14 +-
.../relational/metadata/TableMetadataImpl.java | 6 +-
.../fetcher/TableHeaderSchemaValidator.java | 14 +-
.../fetcher/cache/TableDeviceLastCache.java | 2 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 19 +
.../plan/relational/planner/IrTypeAnalyzer.java | 4 +-
.../relational/planner/SimplePlanRewriter.java | 88 ++
.../distribute/TableDistributedPlanGenerator.java | 24 +
.../MultipleDistinctAggregationToMarkDistinct.java | 202 +++++
...tColumns.java => PruneMarkDistinctColumns.java} | 26 +-
.../rule/SingleDistinctAggregationToGroupBy.java | 160 ++++
.../relational/planner/node/AggregationNode.java | 6 +-
.../relational/planner/node/MarkDistinctNode.java | 162 ++++
.../plan/relational/planner/node/Patterns.java | 7 +-
.../optimizations/LogicalOptimizeFactory.java | 23 +-
.../PushAggregationIntoTableScan.java | 4 +
.../optimizations/PushPredicateIntoTableScan.java | 125 ++-
...mQuantifiedComparisonApplyToCorrelatedJoin.java | 341 ++++++++
.../optimizations/UnaliasSymbolReferences.java | 21 +
.../plan/relational/sql/ast/AstVisitor.java | 12 +
.../{ShowDataNodes.java => RemoveDataNode.java} | 24 +-
...{SetConfiguration.java => StartRepairData.java} | 6 +-
.../{SetConfiguration.java => StopRepairData.java} | 6 +-
.../plan/relational/sql/parser/AstBuilder.java | 38 +-
.../plan/scheduler/ClusterScheduler.java | 4 -
.../plan/scheduler/load/LoadTsFileScheduler.java | 7 +-
.../plan/statement/StatementVisitor.java | 23 +-
.../plan/statement/crud/InsertRowStatement.java | 4 +-
.../plan/statement/crud/InsertTabletStatement.java | 4 +-
.../metadata/AlterTimeSeriesStatement.java | 7 +-
...Statement.java => RemoveDataNodeStatement.java} | 38 +-
.../region/ExtendRegionStatement.java} | 36 +-
.../{ => region}/MigrateRegionStatement.java | 16 +-
.../region/ReconstructRegionStatement.java} | 36 +-
.../region/RemoveRegionStatement.java} | 36 +-
.../AbstractCastFunctionColumnTransformer.java | 43 +-
.../scalar/CastFunctionColumnTransformer.java | 4 +-
.../scalar/TryCastFunctionColumnTransformer.java | 4 +-
.../db/schemaengine/table/DataNodeTableCache.java | 108 ++-
.../db/storageengine/dataregion/DataRegion.java | 37 +-
.../compaction/execute/utils/CompactionUtils.java | 5 +-
.../compaction/repair/RepairDataFileScanUtil.java | 30 +-
.../compaction/schedule/TTLScheduleTask.java | 4 +-
.../selector/impl/SettleSelectorImpl.java | 3 +
.../dataregion/memtable/TsFileProcessor.java | 4 +
.../dataregion/modification/ModificationFile.java | 87 +-
.../dataregion/tsfile/TsFileResource.java | 23 +-
.../broker/SubscriptionPrefetchingQueue.java | 47 +-
.../broker/SubscriptionPrefetchingQueueStates.java | 96 ++-
.../broker/SubscriptionPrefetchingTabletQueue.java | 2 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 2 +-
.../event/SubscriptionCommitContextSupplier.java | 28 -
.../db/subscription/event/SubscriptionEvent.java | 80 +-
.../event/batch/SubscriptionPipeEventBatch.java | 30 -
.../batch/SubscriptionPipeTabletEventBatch.java | 68 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 15 -
.../cache/CachedSubscriptionPollResponse.java | 5 +
.../event/pipe/SubscriptionPipeEmptyEvent.java | 4 +-
.../pipe/SubscriptionPipeTabletBatchEvents.java | 46 +-
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 8 +-
.../pipe/SubscriptionPipeTsFilePlainEvent.java | 8 +-
.../SubscriptionEventExtendableResponse.java | 1 +
.../event/response/SubscriptionEventResponse.java | 10 +-
.../response/SubscriptionEventSingleResponse.java | 1 +
.../response/SubscriptionEventTabletResponse.java | 201 ++++-
.../response/SubscriptionEventTsFileResponse.java | 32 +-
.../db/tools/schema/SRStatementGenerator.java | 7 +-
.../iotdb/db/utils/constant/SqlConstant.java | 1 +
.../dataregion/DataRegionStateMachineTest.java | 4 +-
.../metadata/write/MetadataWriteNodeSerDeTest.java | 2 +-
.../plan/relational/analyzer/DistinctTest.java | 209 +++++
.../plan/relational/planner/SubqueryTest.java | 203 +++++
...onStepMatcher.java => MarkDistinctMatcher.java} | 50 +-
.../planner/assertions/PlanMatchPattern.java | 28 +
.../repair/RepairDataFileScanUtilTest.java | 2 +-
.../modification/ModificationFileTest.java | 58 ++
.../reader/chunk/MemAlignedChunkLoaderTest.java | 2 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 12 +-
.../conf/iotdb-system.properties.template | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 87 +-
.../iotdb/commons/conf/CommonDescriptor.java | 42 +-
.../commons/partition/DataPartitionTable.java | 12 +
.../commons/partition/SeriesPartitionTable.java | 16 +
.../org/apache/iotdb/commons/path/PartialPath.java | 8 +-
.../connector/client/IoTDBSyncClientManager.java | 28 +-
.../connector/protocol/IoTDBAirGapConnector.java | 10 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 4 +
.../schema/table/column/TsTableColumnSchema.java | 19 +
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 27 +
.../subscription/config/SubscriptionConfig.java | 47 +-
.../commons/subscription/meta/topic/TopicMeta.java | 4 +
.../iotdb/commons/udf/access/RecordIterator.java | 9 +-
.../TableBuiltinAggregationFunction.java | 2 +
.../org/apache/iotdb/commons/utils/PathUtils.java | 2 +-
.../iotdb/commons/utils/TimePartitionUtils.java | 13 +
.../db/relational/grammar/sql/RelationalSql.g4 | 22 +-
.../thrift-commons/src/main/thrift/common.thrift | 3 +-
.../src/main/thrift/confignode.thrift | 21 +
.../thrift-datanode/src/main/thrift/client.thrift | 1 +
pom.xml | 13 +-
454 files changed, 17145 insertions(+), 3944 deletions(-)
create mode 100644
example/session/src/main/java/org/apache/iotdb/TableModelSubscriptionSessionExample.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/IoTDBPartitionTableAutoCleanTest.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/{IoTDBRegionMigrateReliabilityITFramework.java
=> IoTDBRegionOperationReliabilityITFramework.java} (82%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/IoTDBRegionReconstructForIoTV1IT.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/IQueryDataSource.java
=>
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/SQLModel.java
(86%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBTableAggregationFunctionDistinctIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/subquery/uncorrelated/IoTDBUncorrelatedQuantifiedComparisonIT.java
rename
integration-test/src/test/java/org/apache/iotdb/relational/it/rest/it/{IoTDBRestServiceInsertAlignedValuesIT.java
=> IoTDBRestServiceInsertValuesIT.java} (96%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/util/MagicUtils.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/AbstractSubscriptionSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ISubscriptionTableSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ISubscriptionTreeSession.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionSessionWrapper.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTableSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTableSessionBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTreeSession.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/SubscriptionTreeSessionBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTablePullConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTablePushConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTreePullConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/ISubscriptionTreePushConsumer.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionConsumer.java
=> base/AbstractSubscriptionConsumer.java} (90%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionProvider.java
=> base/AbstractSubscriptionProvider.java} (93%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionProviders.java
=> base/AbstractSubscriptionProviders.java} (83%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionPullConsumer.java
=> base/AbstractSubscriptionPullConsumer.java} (67%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionPullConsumerBuilder.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{SubscriptionPushConsumer.java
=> base/AbstractSubscriptionPushConsumer.java} (66%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionPushConsumerBuilder.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/{
=> base}/SubscriptionExecutorServiceManager.java (99%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTableProvider.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePullConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePullConsumerBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumerBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreeProvider.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumerBuilder.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumer.java
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/partition/AutoCleanPartitionTablePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/PartitionTableAutoCleaner.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/ReconstructRegionProcedure.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/plugin/env/PipeTaskRuntimeEnvironment.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/RegionOperationProcedure.java}
(54%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{RegionTransitionState.java
=> ReconstructRegionState.java} (93%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/MarkDistinctOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/AggregationMask.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{CountIfAccumulator.java
=> CountAllAccumulator.java} (74%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/{TableScanOperator.java
=> aggregation/MaskedRecordIterator.java} (58%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/hash/MarkDistinctHash.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{MigrateRegionTask.java
=> RemoveDataNodeTask.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{SetTTLTask.java
=> region/ExtendRegionTask.java} (79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{
=> region}/MigrateRegionTask.java (94%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{DropFunctionTask.java
=> region/ReconstructRegionTask.java} (73%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{SetTTLTask.java
=> region/RemoveRegionTask.java} (79%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/SimplePlanRewriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/MultipleDistinctAggregationToMarkDistinct.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneSortColumns.java
=> PruneMarkDistinctColumns.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/SingleDistinctAggregationToGroupBy.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/MarkDistinctNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/TransformQuantifiedComparisonApplyToCorrelatedJoin.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowDataNodes.java
=> RemoveDataNode.java} (70%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{SetConfiguration.java
=> StartRepairData.java} (85%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{SetConfiguration.java
=> StopRepairData.java} (85%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{DropFunctionStatement.java
=> RemoveDataNodeStatement.java} (81%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys/KillQueryStatement.java
=> metadata/region/ExtendRegionStatement.java} (79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{
=> region}/MigrateRegionStatement.java (77%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys/KillQueryStatement.java
=> metadata/region/ReconstructRegionStatement.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{sys/KillQueryStatement.java
=> metadata/region/RemoveRegionStatement.java} (79%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/SubscriptionCommitContextSupplier.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/planner/assertions/{AggregationStepMatcher.java
=> MarkDistinctMatcher.java} (54%)
