This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/fix_code
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4d4070802c3 remove some wrong implementation code
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 43b99192a3c Merge branch 'master' into beyyes/fix_code
add a83693ba07a perfect sub query
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 4c0d4f5e771 Compare in double and fix error message
add 3e11b7bd7ab Fix status code of category or data type mismatch
add efd3420674e Load: Add metrics for active load (#13224)
add c0ad8400ce9 Opt type mismatch error msg & fix Blob and date compare bug
add 60d5a7e60af PipeConsensus: build separate dir for each receiver
thread. (#13234)
add 1f08730d384 Pipe: Support async tsfile load when data syncing between
clusters (#13176)
add d883b100094 Fix the error that columns in sort is not appear in
projection
add 973188fd468 merge master
add 3aeacec83ca add more it
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 | 53 +-
.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 | 20 +-
...iClusterIT2SubscriptionRegressionConsumer.java} | 2 +-
...MultiClusterIT2SubscriptionRegressionMisc.java} | 2 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 2 +-
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 97 +++
.../relational/it/db/it/IoTDBInsertTableIT.java | 288 ++++++--
.../it}/IoTDBMultiIDsWithAttributesTableIT.java | 136 +++-
.../it/db/it/IoTDBSetConfigurationTableIT.java | 23 +-
.../it/query/old/IoTDBNestedQueryTableIT.java | 19 +-
.../scalar/IoTDBScalarFunctionTableIT.java | 822 ++++++++++-----------
.../IoTDBQueryWithComplexValueFilterTableIT.java | 14 +-
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 87 ++-
.../AbstractSubscriptionRegressionIT.java | 8 +
.../IoTDBDefaultPullConsumerDataSetIT.java | 4 +-
.../IoTDBDefaultTsfilePushConsumerIT.java | 4 +-
.../IoTDBRootDatasetPushConsumerIT.java | 4 +-
.../IoTDBRootPullConsumeTsfileIT.java | 4 +-
...merPullConsumerWith1TopicShareProcessMixIT.java | 4 +-
.../param/IoTDBTestParamPullConsumerIT.java | 534 +++++++++++++
.../param/IoTDBTestParamPushConsumerIT.java | 349 +++++++++
.../param/IoTDBTestParamSubscriptionSessionIT.java | 70 ++
.../regression/param/IoTDBTestParamTopicIT.java | 248 +++++++
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 4 +-
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 4 +-
.../format/IoTDBDBDataSetPullConsumerIT.java | 4 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 4 +-
.../IoTDBAllTsDatasetPullConsumerIT.java | 4 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 4 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 4 +-
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 4 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 4 +-
.../IoTDBTimeTsDatasetPullConsumerIT.java | 4 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 4 +-
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 4 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 4 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 4 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 4 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 4 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 4 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 4 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 4 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 4 +-
.../IoTDBDBPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 4 +-
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 4 +-
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 4 +-
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 4 +-
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 4 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 4 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 4 +-
.../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 | 4 +-
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 4 +-
.../format/IoTDBTestPushConsumeTsfileIT.java | 4 +-
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 4 +-
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 4 +-
.../IoTDBLooseAllTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBPathLooseTsfilePushConsumerIT.java | 4 +-
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 4 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 4 +-
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 4 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 4 +-
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 4 +-
...DBConsumer2With1TopicShareProcessDataSetIT.java | 4 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 4 +-
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 4 +-
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 4 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 4 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 4 +-
.../IoTDBDBPatternDatasetPushConsumerIT.java | 4 +-
.../IoTDBDBPatternTsfilePushConsumerIT.java | 4 +-
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 4 +-
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 4 +-
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 4 +-
.../IoTDBRootPatternDatasetPushConsumerIT.java | 4 +-
.../IoTDBTSPatternDatasetPushConsumerIT.java | 4 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 4 +-
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 4 +-
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 4 +-
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 4 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 4 +-
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 4 +-
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 4 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 4 +-
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 4 +-
.../regression/topic/IoTDBTestTopicNameIT.java | 4 +-
.../IoTDBOtherUserConsumerIT.java} | 87 +--
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
.../iotdb/confignode/manager/ProcedureManager.java | 121 ++-
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 2 +
.../protocol/IoTDBConfigRegionConnector.java | 6 +-
.../procedure/env/RegionMaintainHandler.java | 49 +-
.../impl/region/RemoveRegionPeerProcedure.java | 23 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 78 ++
.../iotdb/consensus/ratis/RatisConsensus.java | 33 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 15 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 23 +
.../iotdb/db/exception/sql/SemanticException.java | 8 +
.../client/IoTDBDataNodeAsyncClientManager.java | 32 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../evolvable/batch/PipeTabletEventBatch.java | 19 +-
.../batch/PipeTransferBatchReqBuilder.java | 5 +
.../airgap/IoTDBDataNodeAirGapConnector.java | 2 +
.../async/IoTDBDataRegionAsyncConnector.java | 9 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 5 +
.../scan/TsFileInsertionScanDataContainer.java | 134 +++-
.../pipeconsensus/PipeConsensusReceiver.java | 61 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 32 +-
...peStatementDataTypeConvertExecutionVisitor.java | 54 +-
.../visitor/PipeStatementExceptionVisitor.java | 2 +-
.../visitor/PipeStatementPatternParseVisitor.java | 12 +
.../visitor/PipeStatementTSStatusVisitor.java | 4 +-
.../visitor/PipeStatementToBatchVisitor.java | 28 +-
.../subtask/connector/PipeConnectorSubtask.java | 5 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 25 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../execution/exchange/source/SourceHandle.java | 12 +
.../execution/executor/RegionExecutionResult.java | 21 +-
.../execution/executor/RegionReadExecutor.java | 42 +-
.../execution/executor/RegionWriteExecutor.java | 132 ++--
.../fragment/FragmentInstanceContext.java | 10 +-
.../relational/ColumnTransformerBuilder.java | 35 +-
.../execution/schedule/AbstractDriverThread.java | 10 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 9 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 8 +-
.../plan/analyze/LoadTsFileAnalyzer.java | 4 +-
.../plan/analyze/schema/SchemaValidator.java | 2 +-
.../queryengine/plan/execution/QueryExecution.java | 12 +
.../execution/config/TreeConfigTaskVisitor.java | 2 +-
.../multi/builtin/helper/CastFunctionHelper.java | 6 +-
.../plan/planner/LogicalPlanVisitor.java | 4 +-
.../plan/planner/TableOperatorGenerator.java | 3 +-
.../plan/node/load/LoadTsFilePieceNode.java | 2 +-
.../plan/node/metadata/write/MeasurementGroup.java | 8 +-
.../relational/metadata/TableMetadataImpl.java | 111 ++-
.../fetcher/TableHeaderSchemaValidator.java | 19 +-
.../plan/relational/planner/PredicateUtils.java | 165 -----
.../planner/iterative/rule/MergeFilters.java | 3 +
.../rule/MergeLimitOverProjectWithMergeSort.java | 4 +-
.../rule/MergeLimitOverProjectWithSort.java | 16 +-
.../iterative/rule/MergeLimitWithMergeSort.java | 8 +-
.../planner/iterative/rule/MergeLimitWithSort.java | 13 +-
.../planner/iterative/rule/MergeLimits.java | 3 +
.../PushLimitOffsetIntoTableScan.java | 75 +-
.../planner/optimizations/SortElimination.java | 7 +-
.../optimizations/TransformSortToStreamSort.java | 18 +
.../relational/sql/ast/WrappedInsertStatement.java | 25 +-
.../plan/relational/sql/parser/AstBuilder.java | 45 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 12 +-
.../plan/statement/StatementVisitor.java | 8 +-
.../plan/statement/crud/InsertBaseStatement.java | 14 +-
.../crud/InsertMultiTabletsStatement.java | 4 +-
.../plan/statement/crud/InsertRowStatement.java | 6 +-
.../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 +-
.../binary/CompareBinaryColumnTransformer.java | 3 +-
.../column/unary/scalar/AcosColumnTransformer.java | 3 +-
.../column/unary/scalar/AsinColumnTransformer.java | 3 +-
.../column/unary/scalar/AtanColumnTransformer.java | 3 +-
.../scalar/CastFunctionColumnTransformer.java | 149 +++-
.../column/unary/scalar/CeilColumnTransformer.java | 3 +-
.../column/unary/scalar/CosColumnTransformer.java | 3 +-
.../column/unary/scalar/CoshColumnTransformer.java | 3 +-
.../unary/scalar/DegreesColumnTransformer.java | 3 +-
.../column/unary/scalar/ExpColumnTransformer.java | 3 +-
.../unary/scalar/FloorColumnTransformer.java | 3 +-
.../column/unary/scalar/LnColumnTransformer.java | 3 +-
.../unary/scalar/Log10ColumnTransformer.java | 3 +-
.../unary/scalar/RadiansColumnTransformer.java | 3 +-
.../column/unary/scalar/SignColumnTransformer.java | 3 +-
.../column/unary/scalar/SinColumnTransformer.java | 3 +-
.../column/unary/scalar/SinhColumnTransformer.java | 3 +-
.../column/unary/scalar/SqrtColumnTransformer.java | 3 +-
.../column/unary/scalar/TanColumnTransformer.java | 3 +-
.../column/unary/scalar/TanhColumnTransformer.java | 3 +-
.../attribute/DeviceAttributeStore.java | 34 +-
.../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 16 +
.../db/service/metrics/DataNodeMetricsHelper.java | 6 +-
.../iotdb/db/storageengine/StorageEngine.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 2 +-
.../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/utils/TsFileResourceUtils.java | 19 +-
.../load/LoadTsFileManager.java | 22 +-
.../storageengine/load/active/ActiveLoadAgent.java | 51 ++
.../load/active/ActiveLoadDirScanner.java | 77 +-
.../load/active/ActiveLoadMetricsCollector.java | 96 +++
.../load/active/ActiveLoadPendingQueue.java | 11 +-
.../active/ActiveLoadScheduledExecutorService.java | 107 +++
.../load/active/ActiveLoadTsFileLoader.java | 79 +-
.../load/limiter/LoadTsFileRateLimiter.java | 4 +-
.../memory}/LoadTsFileAbstractMemoryBlock.java | 2 +-
.../LoadTsFileAnalyzeSchemaMemoryBlock.java | 4 +-
.../memory}/LoadTsFileDataCacheMemoryBlock.java | 2 +-
.../load/memory}/LoadTsFileMemoryManager.java | 2 +-
.../load/metrics/ActiveLoadingFilesMetricsSet.java | 113 +++
.../load/metrics}/LoadTsFileCostMetricsSet.java | 2 +-
.../load/metrics}/LoadTsFileMemMetricSet.java | 4 +-
.../load/splitter/AlignedChunkData.java | 74 +-
.../splitter/BatchedAlignedValueChunkData.java | 237 ++++++
.../load/splitter/ChunkData.java | 2 +-
.../load/splitter/DeletionData.java | 2 +-
.../load/splitter/NonAlignedChunkData.java | 2 +-
.../load/splitter/TsFileData.java | 2 +-
.../load/splitter/TsFileSplitter.java | 469 +++++++-----
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 38 +-
.../PipeStatementPatternParseVisitorTest.java | 54 +-
.../event/TsFileInsertionDataContainerTest.java | 553 ++++----------
.../extractor/PipePlanPatternParseVisitorTest.java | 104 +--
.../plan/relational/analyzer/SortTest.java | 229 +++---
.../plan/relational/analyzer/SubQueryTest.java | 258 +++++++
.../planner/assertions/OffsetMatcher.java | 6 +
.../relational/planner/assertions/PlanAssert.java | 3 +-
.../planner/assertions/PlanMatchPattern.java | 5 +
.../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 +-
.../conf/iotdb-system.properties.template | 6 +
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../org/apache/iotdb/commons/path/PartialPath.java | 9 +
.../config/constant/PipeConnectorConstant.java | 11 +
.../connector/client/IoTDBSyncClientManager.java | 8 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../pipe/connector/protocol/IoTDBConnector.java | 28 +
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 14 +
.../schema/table/column/TsTableColumnSchema.java | 4 +
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 53 ++
309 files changed, 10270 insertions(+), 3708 deletions(-)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2SubscriptionRegression.java
=> MultiClusterIT2SubscriptionRegressionConsumer.java} (92%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2SubscriptionRegression.java
=> MultiClusterIT2SubscriptionRegressionMisc.java} (93%)
rename
integration-test/src/test/java/org/apache/iotdb/relational/it/{query/old/orderBy
=> db/it}/IoTDBMultiIDsWithAttributesTableIT.java (82%)
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
copy
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/{pullconsumer/format/IoTDBDBDataSetPullConsumerIT.java
=> user/IoTDBOtherUserConsumerIT.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/MergeFilters.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/MergeLimits.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/MultiClusterIT2SubscriptionRegression.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
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/LoadTsFileManager.java (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadAgent.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/active/ActiveLoadDirScanner.java (74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadMetricsCollector.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/active/ActiveLoadPendingQueue.java (81%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadScheduledExecutorService.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/active/ActiveLoadTsFileLoader.java (79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/limiter/LoadTsFileRateLimiter.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/load
=> storageengine/load/memory}/LoadTsFileAbstractMemoryBlock.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/load
=> storageengine/load/memory}/LoadTsFileAnalyzeSchemaMemoryBlock.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/load
=> storageengine/load/memory}/LoadTsFileDataCacheMemoryBlock.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/load
=> storageengine/load/memory}/LoadTsFileMemoryManager.java (99%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/ActiveLoadingFilesMetricsSet.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/metric/load
=> storageengine/load/metrics}/LoadTsFileCostMetricsSet.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/metric/load
=> storageengine/load/metrics}/LoadTsFileMemMetricSet.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/AlignedChunkData.java (89%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/BatchedAlignedValueChunkData.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/ChunkData.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/DeletionData.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/NonAlignedChunkData.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/TsFileData.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/TsFileSplitter.java (50%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SubQueryTest.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
