This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch speed_up_recover
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 1e86efcb7a3 fix empty FileTimeIndexCache
add f5b4b8fee46 batch serialize
add 280f0a4512d control the thread number of recover
add 96d977987da fix cannot start recover task
add 5f5a404e8f3 fix delete region
add 246ab58b05f Add string and math function
add 32df6dfc2e3 Eventually consistent heartbeat samples #13210
add 95378c9b89f Pipe: Reduced the recover time in cleaning tsFile
hardlinks (#13216)
add ad675479751 [region migration] Snapshot source file not exists problem
debugging #13214
add b9aeda95a64 Subscription IT: intro extensive regression tests from
test group (#13065)
add cd8a4610fb3 Pipe: The DataRegion migration process checks whether the
user pipe has released all related resources (#13183)
add b88c82b5ced Avoid the brain split phenomenon in the symmetric network
partition scenario #13221
add e4f10fe89fb [region migration] Do RatisConsensus resetPeerList even if
myself not in peer list #13223
add 45ab21bf8e3 RegionMigrate: Fix migrating region with ratisConsensus
cause the region is unavailable. (#13178)
add 61622d9804c Fixed the bug of device attribute update
add 69c010c88d6 Pipe: Update TsFileInsertionScanDataContainer to support
partially sequential aligned chunks (#13168)
add aac66ce5708 Modify 'set configuration' in relational grammar (#13186)
add dd3d516a739 Pipe: Fix InternalCreateMultiTimeSeries plan's members may
be altered in SchemaRegionListeningQueue & Alter timeseries for logical view is
not parsed in snapshot transferring (#13123)
add e1861849160 Reduce aligned series compaction memory usage (#12744)
add 8888377619e [region migration] Fix regionRWLock NPE when migrating
region concurrently (#13217)
add 00a5c40b088 Pipe IT: Reduce FT runner cost by removing some
manual-create-schema test cases (#13242)
add 1ee4744718f Pipe: Convert tsfile to tablets on data sync receiver when
data type / aligned type mismatch detected (#13239)
add a54f7f7be51 Make DN wait when CN cluster's leader is not ready or
down. (#13236)
add 2ee04519aba fix scalar function args and return type problem
add 1107bf70e1d Subscription IT: migrate regression tests of parameter and
permission from test group (#13231)
add b158e60cafc Fix insert statement creation when there is only one column
add 5c5c9226081 Fixed the granularity of table procedure lock
add 1489c8480ef Pipe: discard batched events before restarting pipes
(#13238)
add a32eef95678 Fix database and tablename case sensitivity in tablet model
add 3bb5b076a71 Merge branch 'master' of github.com:apache/iotdb into
speed_up_recover
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 2 -
.github/workflows/cluster-it-1c3d.yml | 2 -
.github/workflows/pipe-it-2cluster.yml | 96 +-
.github/workflows/table-cluster-it-1c1d.yml | 2 -
.github/workflows/table-cluster-it-1c3d.yml | 2 -
.github/workflows/unit-test.yml | 2 -
integration-test/pom.xml | 34 +-
...ltiClusterIT2SubscriptionArchVerification.java} | 2 +-
...iClusterIT2SubscriptionRegressionConsumer.java} | 2 +-
...MultiClusterIT2SubscriptionRegressionMisc.java} | 2 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 229 +-
.../it/db/it/IoTDBSetConfigurationTableIT.java | 23 +-
.../scalar/IoTDBScalarFunctionTableIT.java | 2612 ++++++++++++++++++++
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 3 +-
.../subscription/it/AbstractSubscriptionIT.java | 13 +-
.../apache/iotdb/subscription/it/DisplayName.java} | 20 +-
.../it/SkipOnSetUpAndTearDownFailure.java | 114 +
.../iotdb/subscription/it/SkipOnSetUpFailure.java | 82 -
.../it/cluster/IoTDBSubscriptionRestartIT.java | 98 +-
.../it/dual/AbstractSubscriptionDualIT.java | 10 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 10 +-
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 6 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 18 +-
.../it/local/AbstractSubscriptionLocalIT.java | 10 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 4 +-
.../it/local/IoTDBSubscriptionDataTypeIT.java | 2 +-
.../it/triple/AbstractSubscriptionTripleIT.java | 10 +-
.../it/triple/IoTDBSubscriptionSharingIT.java | 18 +-
.../AbstractSubscriptionRegressionIT.java | 475 ++++
.../IoTDBDefaultPullConsumerDataSetIT.java | 142 ++
.../IoTDBDefaultTsfilePushConsumerIT.java | 224 ++
.../IoTDBRootDatasetPushConsumerIT.java | 186 ++
.../IoTDBRootPullConsumeTsfileIT.java | 147 ++
...merPullConsumerWith1TopicShareProcessMixIT.java | 196 ++
.../param/IoTDBTestParamPullConsumerIT.java | 534 ++++
.../param/IoTDBTestParamPushConsumerIT.java | 349 +++
.../param/IoTDBTestParamSubscriptionSessionIT.java | 70 +
.../regression/param/IoTDBTestParamTopicIT.java | 248 ++
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 191 ++
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 175 ++
.../format/IoTDBDBDataSetPullConsumerIT.java | 154 ++
.../format/IoTDBDBTsfilePullConsumerIT.java | 155 ++
.../IoTDBAllTsDatasetPullConsumerIT.java | 208 ++
.../IoTDBAllTsTsfilePullConsumerIT.java | 199 ++
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 201 ++
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 170 ++
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 189 ++
.../IoTDBTimeTsDatasetPullConsumerIT.java | 212 ++
.../IoTDBTimeTsTsfilePullConsumerIT.java | 203 ++
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 152 ++
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 182 ++
...DBConsumer2With1TopicShareProcessDataSetIT.java | 145 ++
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 198 ++
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 215 ++
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 183 ++
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 319 +++
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 211 ++
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 177 ++
.../IoTDBDBPatternPullConsumerDataSetIT.java | 150 ++
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 145 ++
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 176 ++
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 156 ++
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 174 ++
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 177 ++
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 184 ++
.../IoTDBRootPatternPullConsumeTsfileIT.java | 152 ++
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 182 ++
.../IoTDBTSPatternPullConsumerDataSetIT.java | 132 +
.../time/IoTDBAllPullConsumerDataSetIT.java | 131 +
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 139 ++
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 138 ++
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 136 +
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 140 ++
.../format/IoTDBTestPushConsumeDataSetIT.java | 179 ++
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 181 ++
.../format/IoTDBTestPushConsumeTsfileIT.java | 181 ++
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 228 ++
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 227 ++
.../IoTDBLooseAllTsfilePushConsumerIT.java | 257 ++
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 254 ++
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 255 ++
.../IoTDBPathLooseTsfilePushConsumerIT.java | 224 ++
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 209 ++
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 220 ++
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 277 +++
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 237 ++
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 219 ++
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 196 ++
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 246 ++
...DBConsumer2With1TopicShareProcessDataSetIT.java | 216 ++
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 223 ++
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 604 +++++
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 202 ++
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 239 ++
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 211 ++
.../IoTDBDBPatternDatasetPushConsumerIT.java | 191 ++
.../IoTDBDBPatternTsfilePushConsumerIT.java | 221 ++
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 220 ++
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 190 ++
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 233 ++
.../IoTDBRootPatternDatasetPushConsumerIT.java | 191 ++
.../IoTDBTSPatternDatasetPushConsumerIT.java | 190 ++
.../IoTDBTSPatternTsfilePushConsumerIT.java | 227 ++
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 175 ++
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 178 ++
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 164 ++
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 180 ++
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 180 ++
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 181 ++
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 199 ++
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 142 ++
.../regression/topic/IoTDBTestTopicNameIT.java | 139 ++
.../regression/user/IoTDBOtherUserConsumerIT.java | 143 ++
.../statemachine/ConfigRegionStateMachine.java | 65 +-
.../iotdb/confignode/manager/ProcedureManager.java | 121 +-
.../manager/load/cache/AbstractLoadCache.java | 2 +-
.../procedure/env/RegionMaintainHandler.java | 49 +-
.../impl/region/RemoveRegionPeerProcedure.java | 23 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 7 +-
.../consensus/iot/IoTConsensusServerImpl.java | 5 +-
.../service/IoTConsensusRPCServiceProcessor.java | 3 +-
.../ratis/ApplicationStateMachineProxy.java | 6 +
.../apache/iotdb/consensus/ratis/RatisClient.java | 78 +
.../iotdb/consensus/ratis/RatisConsensus.java | 36 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 15 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 23 +
.../dataregion/DataRegionStateMachine.java | 11 +-
.../schemaregion/SchemaRegionStateMachine.java | 29 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 15 +
.../evolvable/batch/PipeTabletEventBatch.java | 19 +-
.../batch/PipeTransferBatchReqBuilder.java | 5 +
.../async/IoTDBDataRegionAsyncConnector.java | 6 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 5 +
.../scan/TsFileInsertionScanDataContainer.java | 134 +-
...peStatementDataTypeConvertExecutionVisitor.java | 54 +-
.../visitor/PipeStatementExceptionVisitor.java | 2 +-
.../visitor/PipeStatementPatternParseVisitor.java | 12 +
.../visitor/PipeStatementTSStatusVisitor.java | 4 +-
.../visitor/PipeStatementToBatchVisitor.java | 28 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 21 +-
.../subtask/connector/PipeConnectorSubtask.java | 5 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 25 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../execution/executor/RegionExecutionResult.java | 21 +-
.../execution/executor/RegionReadExecutor.java | 42 +-
.../execution/executor/RegionWriteExecutor.java | 132 +-
.../execution/load/LoadTsFileManager.java | 5 +
.../execution/load/splitter/AlignedChunkData.java | 72 +-
.../splitter/BatchedAlignedValueChunkData.java | 237 ++
.../execution/load/splitter/TsFileSplitter.java | 467 ++--
.../relational/ColumnTransformerBuilder.java | 295 ++-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 4 +-
.../plan/analyze/schema/SchemaValidator.java | 2 +-
.../execution/config/TreeConfigTaskVisitor.java | 2 +-
.../plan/planner/LogicalPlanVisitor.java | 4 +-
.../plan/node/metadata/write/MeasurementGroup.java | 8 +-
.../relational/metadata/TableMetadataImpl.java | 281 ++-
.../fetcher/TableHeaderSchemaValidator.java | 2 +-
.../plan/relational/planner/TranslationMap.java | 19 +
.../relational/planner/ir/ExpressionRewriter.java | 5 +
.../planner/ir/ExpressionTreeRewriter.java | 23 +
.../plan/relational/planner/ir/IrVisitor.java | 5 +
.../relational/planner/ir/RewritingVisitor.java | 19 +
.../relational/sql/ast/WrappedInsertStatement.java | 4 +-
.../plan/relational/sql/parser/AstBuilder.java | 45 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../plan/statement/StatementVisitor.java | 8 +-
.../plan/statement/crud/InsertBaseStatement.java | 14 +-
.../crud/InsertMultiTabletsStatement.java | 4 +-
.../plan/statement/crud/InsertRowStatement.java | 2 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 4 +-
.../plan/statement/crud/InsertRowsStatement.java | 4 +-
.../plan/statement/crud/InsertTabletStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 26 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 2 +-
.../column/unary/scalar/AbsColumnTransformer.java | 56 +
.../column/unary/scalar/AcosColumnTransformer.java | 53 +
.../column/unary/scalar/AsinColumnTransformer.java | 53 +
.../column/unary/scalar/AtanColumnTransformer.java | 53 +
.../column/unary/scalar/CeilColumnTransformer.java | 53 +
.../unary/scalar/Concat2ColumnTransformer.java | 61 +
.../unary/scalar/ConcatColumnTransformer.java | 66 +
.../unary/scalar/ConcatMultiColumnTransformer.java | 74 +
.../column/unary/scalar/CosColumnTransformer.java | 53 +
.../column/unary/scalar/CoshColumnTransformer.java | 53 +
.../unary/scalar/DegreesColumnTransformer.java | 53 +
.../unary/scalar/EndsWith2ColumnTransformer.java | 56 +
.../unary/scalar/EndsWithColumnTransformer.java | 52 +
.../column/unary/scalar/ExpColumnTransformer.java | 53 +
.../unary/scalar/FloorColumnTransformer.java | 53 +
.../unary/scalar/LTrim2ColumnTransformer.java | 56 +
.../unary/scalar/LTrimColumnTransformer.java | 70 +
.../unary/scalar/LengthColumnTransformer.java | 47 +
.../column/unary/scalar/LnColumnTransformer.java | 53 +
.../unary/scalar/Log10ColumnTransformer.java | 53 +
.../unary/scalar/LowerColumnTransformer.java | 47 +
.../unary/scalar/RTrim2ColumnTransformer.java | 56 +
.../unary/scalar/RTrimColumnTransformer.java | 70 +
.../unary/scalar/RadiansColumnTransformer.java | 53 +
.../unary/scalar/RegexpLike2ColumnTransformer.java | 54 +
.../unary/scalar/RegexpLikeColumnTransformer.java | 52 +
.../column/unary/scalar/SignColumnTransformer.java | 53 +
.../column/unary/scalar/SinColumnTransformer.java | 53 +
.../column/unary/scalar/SinhColumnTransformer.java | 53 +
.../column/unary/scalar/SqrtColumnTransformer.java | 53 +
.../unary/scalar/StartsWith2ColumnTransformer.java | 55 +
.../unary/scalar/StartsWithColumnTransformer.java | 61 +
.../unary/scalar/Strcmp2ColumnTransformer.java | 54 +
.../unary/scalar/StrcmpColumnTransformer.java | 50 +
.../unary/scalar/Strpos2ColumnTransformer.java | 54 +
.../unary/scalar/StrposColumnTransformer.java | 50 +
.../unary/scalar/TableBuiltinScalarFunction.java | 70 +
.../column/unary/scalar/TanColumnTransformer.java | 53 +
.../column/unary/scalar/TanhColumnTransformer.java | 53 +
.../unary/scalar/Trim2ColumnTransformer.java | 56 +
.../column/unary/scalar/TrimColumnTransformer.java | 82 +
.../unary/scalar/UpperColumnTransformer.java | 48 +
.../attribute/DeviceAttributeStore.java | 34 +-
.../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 16 +
.../iotdb/db/storageengine/StorageEngine.java | 22 +-
.../db/storageengine/dataregion/DataRegion.java | 4 +-
.../BatchCompactionCannotAlignedException.java | 55 +
.../impl/ReadChunkCompactionPerformer.java | 6 +-
.../impl/ReadPointCompactionPerformer.java | 6 +-
.../execute/task/InnerSpaceCompactionTask.java | 8 +-
.../subtask/FastCompactionPerformerSubTask.java | 50 +-
.../task/subtask/ReadPointPerformerSubTask.java | 4 +-
.../execute/utils/CompactionPathUtils.java | 2 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 387 +++
...edReadChunkAlignedSeriesCompactionExecutor.java | 426 ++++
.../utils/AlignedSeriesBatchCompactionUtils.java | 176 ++
.../executor/batch/utils/BatchCompactionPlan.java | 68 +
.../BatchedCompactionAlignedPagePointReader.java | 95 +
.../batch/utils/ChunkWriterFlushCallback.java | 9 +-
.../executor/batch/utils/CompactChunkPlan.java | 70 +
.../utils/CompactPagePlan.java} | 52 +-
.../FirstBatchCompactionAlignedChunkWriter.java | 187 ++
...FollowingBatchCompactionAlignedChunkWriter.java | 266 ++
...va => FastAlignedSeriesCompactionExecutor.java} | 243 +-
...=> FastNonAlignedSeriesCompactionExecutor.java} | 34 +-
.../executor/fast/SeriesCompactionExecutor.java | 65 +-
.../executor/fast/element/AlignedPageElement.java | 19 +-
.../fast/element/ChunkMetadataElement.java | 11 +-
.../utils/executor/fast/element/PageElement.java | 2 +-
.../fast/reader/CompactionAlignedChunkReader.java | 29 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 109 +-
.../executor/readchunk/loader/ChunkLoader.java | 8 +-
.../readchunk/loader/InstantChunkLoader.java | 7 +-
.../readchunk/loader/InstantPageLoader.java | 8 +-
.../executor/readchunk/loader/PageLoader.java | 18 +-
.../utils/writer/AbstractCompactionWriter.java | 47 +-
.../utils/writer/FastCrossCompactionWriter.java | 105 +-
.../utils/writer/FastInnerCompactionWriter.java | 97 +-
.../writer/ReadPointCrossCompactionWriter.java | 48 +-
.../writer/ReadPointInnerCompactionWriter.java | 37 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 6 +-
.../AbstractCompactionFlushController.java} | 45 +-
.../FollowedBatchedCompactionFlushController.java | 68 +
.../estimator/AbstractCrossSpaceEstimator.java | 3 +
.../estimator/AbstractInnerSpaceEstimator.java | 3 +
.../estimator/CompactionEstimateUtils.java | 9 +
.../FastCompactionInnerCompactionEstimator.java | 23 +-
.../FastCrossSpaceCompactionEstimator.java | 27 +-
.../ReadChunkInnerCompactionEstimator.java | 21 +-
.../RepairUnsortedFileCompactionEstimator.java | 10 +
.../impl/RewriteCrossSpaceCompactionSelector.java | 10 +-
.../dataregion/snapshot/SnapshotTaker.java | 34 +-
.../dataregion/tsfile/TsFileResource.java | 5 +-
.../timeindex/FileTimeIndexCacheRecorder.java | 76 +-
.../dataregion/utils/TsFileResourceUtils.java | 19 +-
.../FileTimeIndexCacheWriter.java | 2 +-
.../PipeStatementPatternParseVisitorTest.java | 54 +-
.../event/TsFileInsertionDataContainerTest.java | 553 +----
.../extractor/PipePlanPatternParseVisitorTest.java | 104 +-
.../compaction/AbstractCompactionTest.java | 101 +
.../BatchedCompactionWithTsFileSplitterTest.java | 350 +++
.../FastCompactionPerformerWithEmptyPageTest.java | 8 +
...InconsistentCompressionTypeAndEncodingTest.java | 13 +-
...tchedAlignedSeriesCrossSpaceCompactionTest.java | 510 ++++
.../cross/RewriteCompactionFileSelectorTest.java | 6 +
...atchedAlignedSeriesFastInnerCompactionTest.java | 415 ++++
...tchedAlignedSeriesReadChunkCompactionTest.java} | 503 ++--
.../inner/FastCompactionPerformerAlignedTest.java | 64 +-
.../FastCompactionPerformerNoAlignedTest.java | 36 +-
...nkCompactionPerformerWithAlignedSeriesTest.java | 456 ++--
.../ReadChunkCompactionPerformerAlignedTest.java | 64 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +-
.../compaction/utils/BatchCompactionUtilsTest.java | 293 +++
.../compaction/utils/CompactionCheckerUtils.java | 130 +-
.../compaction/utils/CompactionTestFileWriter.java | 39 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +
.../conf/iotdb-system.properties.template | 6 +
.../org/apache/iotdb/commons/path/PartialPath.java | 9 +
.../pipe/connector/protocol/IoTDBConnector.java | 8 +
.../AbstractSerializableListeningQueue.java | 4 +-
.../iotdb/commons/pipe/task/PipeTaskManager.java | 13 +
.../iotdb/commons/schema/SchemaConstant.java | 1 +
299 files changed, 30152 insertions(+), 2535 deletions(-)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2Subscription.java
=> MultiClusterIT2SubscriptionArchVerification.java} (93%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2Subscription.java
=> MultiClusterIT2SubscriptionRegressionConsumer.java} (92%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2Subscription.java
=> MultiClusterIT2SubscriptionRegressionMisc.java} (93%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBScalarFunctionTableIT.java
copy
integration-test/src/{main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=> test/java/org/apache/iotdb/subscription/it/DisplayName.java} (67%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/SkipOnSetUpAndTearDownFailure.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/SkipOnSetUpFailure.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/AbstractSubscriptionRegressionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/mix/IoTDBPushConsumerPullConsumerWith1TopicShareProcessMixIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamSubscriptionSessionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamTopicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitFalseDataSetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitTrueDataSetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBDataSetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBTsfilePullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsDatasetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsTsfilePullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsfilePullConsumerSnapshotIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceDataSetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceTsfilePullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsDatasetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsTsfilePullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDefaultPatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatch2PatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBRootPatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBAllPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBHistoryPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBRealTimePullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangeAccuratePullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangePullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeNoTargetDirTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerSnapshotIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseDeviceTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathTsLooseDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeTsLooseDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDefaultPatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBRootPatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootTsFilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeAccurateDBDataSetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBDataSetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBDataSet1TopicConsumerSpecialIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBTestTopicNameIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/user/IoTDBOtherUserConsumerIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/load/splitter/BatchedAlignedValueChunkData.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AbsColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AcosColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AsinColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AtanColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CeilColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Concat2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ConcatColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ConcatMultiColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CosColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CoshColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DegreesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/EndsWith2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/EndsWithColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ExpColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FloorColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LTrim2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LTrimColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LengthColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LnColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Log10ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LowerColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RTrim2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RTrimColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RadiansColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RegexpLike2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RegexpLikeColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SignColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinhColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SqrtColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/StartsWith2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/StartsWithColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Strcmp2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/StrcmpColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Strpos2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/StrposColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TableBuiltinScalarFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanhColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Trim2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TrimColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/UpperColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/BatchCompactionCannotAlignedException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/BatchedFastAlignedSeriesCompactionExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/BatchedReadChunkAlignedSeriesCompactionExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/AlignedSeriesBatchCompactionUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/BatchCompactionPlan.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/BatchedCompactionAlignedPagePointReader.java
rename
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/ChunkWriterFlushCallback.java
(75%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/CompactChunkPlan.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/{fast/element/ChunkMetadataElement.java
=> batch/utils/CompactPagePlan.java} (50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/FirstBatchCompactionAlignedChunkWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/FollowingBatchCompactionAlignedChunkWriter.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/{AlignedSeriesCompactionExecutor.java
=> FastAlignedSeriesCompactionExecutor.java} (70%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/{NonAlignedSeriesCompactionExecutor.java
=> FastNonAlignedSeriesCompactionExecutor.java} (88%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/{executor/fast/element/ChunkMetadataElement.java
=> writer/flushcontroller/AbstractCompactionFlushController.java} (50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/flushcontroller/FollowedBatchedCompactionFlushController.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/BatchedCompactionWithTsFileSplitterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/cross/BatchedAlignedSeriesCrossSpaceCompactionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/BatchedAlignedSeriesFastInnerCompactionTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/{NewReadChunkCompactionPerformerWithAlignedSeriesTest.java
=> BatchedAlignedSeriesReadChunkCompactionTest.java} (59%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/BatchCompactionUtilsTest.java
