This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch auth in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 591f1af5fa8d27feba86315c02374e3af839977e Merge: 0d104e84343 7356c8a435c Author: JackieTien97 <[email protected]> AuthorDate: Tue Aug 29 14:24:01 2023 +0800 Merge remote-tracking branch 'origin/master' into auth iotdb-connector/flink-sql-iotdb-connector/pom.xml | 2 +- iotdb-core/consensus/pom.xml | 2 +- .../pipe/agent/runtime/PipeCronEventInjector.java | 70 ++++++++ .../db/pipe/agent/runtime/PipeRuntimeAgent.java | 7 +- .../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 2 +- .../config/constant/PipeConnectorConstant.java | 2 +- .../event/common/heartbeat/PipeHeartbeatEvent.java | 12 +- .../event/realtime/PipeRealtimeEventFactory.java | 6 +- .../PipeRealtimeDataRegionHybridExtractor.java | 9 +- .../PipeRealtimeDataRegionLogExtractor.java | 9 +- .../PipeRealtimeDataRegionTsFileExtractor.java | 7 + .../listener/PipeInsertionDataNodeListener.java | 6 +- .../pipe/task/connection/BlockingPendingQueue.java | 2 +- .../pipe/task/connection/PipeEventCollector.java | 13 +- .../connection/UnboundedBlockingPendingQueue.java | 12 +- .../planner/plan/node/write/DeleteDataNode.java | 12 +- .../db/storageengine/dataregion/DataRegion.java | 3 + .../executor/fast/SeriesCompactionExecutor.java | 11 +- .../utils/executor/fast/element/PageElement.java | 9 +- .../utils/executor/fast/element/PointElement.java | 7 +- .../execute/utils/reader/PointPriorityReader.java | 14 +- .../compaction/selector/ICompactionSelector.java | 4 +- .../estimator/AbstractCompactionEstimator.java | 121 ++++++++++--- .../estimator/AbstractCrossSpaceEstimator.java | 27 ++- .../estimator/AbstractInnerSpaceEstimator.java | 77 +------- .../estimator/CompactionEstimateUtils.java | 3 +- .../selector/estimator/CompactionTaskInfo.java | 101 +++++++++++ .../FastCompactionInnerCompactionEstimator.java | 72 +++++--- .../FastCrossSpaceCompactionEstimator.java | 81 +++++++++ .../estimator/InplaceCompactionEstimator.java | 172 ------------------ .../ReadChunkInnerCompactionEstimator.java | 38 ++-- .../ReadPointCrossCompactionEstimator.java | 197 --------------------- .../impl/RewriteCrossSpaceCompactionSelector.java | 21 ++- .../utils/CrossCompactionTaskResource.java | 6 +- .../db/storageengine/rescon/memory/SystemInfo.java | 3 + .../compaction/CompactionSchedulerTest.java | 1 - .../FastCompactionPerformerWithEmptyPageTest.java | 137 ++++++++++++++ .../utils/CompactionTaskMemCostEstimatorTest.java | 22 ++- .../compaction/utils/CompactionTestFileWriter.java | 99 ++++++++++- .../iotdb/commons/concurrent/ThreadName.java | 2 + .../read/reader/chunk/AlignedChunkReader.java | 6 +- .../tsfile/read/reader/page/AlignedPageReader.java | 5 + .../page/LazyLoadAlignedPagePointReader.java | 97 ++++++++++ .../reader/LazyLoadAlignedPagePointReaderTest.java | 177 ++++++++++++++++++ 44 files changed, 1123 insertions(+), 563 deletions(-)
