You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2024/01/17 11:16:28 UTC
(iotdb) branch master updated (22f915f3159 -> da790779d13)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 22f915f3159 Strictly check inner space compaction file size (#11919)
add da790779d13 Read chunk aligned series compaction executor (#11745)
No new revisions were added by this update.
Summary of changes:
.../impl/ReadChunkCompactionPerformer.java | 12 +-
.../execute/task/CompactionTaskSummary.java | 44 +-
.../execute/utils/executor/ModifiedStatus.java} | 10 +-
.../fast/AlignedSeriesCompactionExecutor.java | 1 +
.../fast/NonAlignedSeriesCompactionExecutor.java | 1 +
.../executor/fast/SeriesCompactionExecutor.java | 6 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 472 +++++++++++++++
.../readchunk/SingleSeriesCompactionExecutor.java | 4 +-
.../executor/readchunk/loader/ChunkLoader.java | 104 ++++
.../readchunk/loader/InstantChunkLoader.java | 105 ++++
.../readchunk/loader/InstantPageLoader.java | 103 ++++
.../executor/readchunk/loader/PageLoader.java | 107 ++++
.../compaction/io/CompactionTsFileReader.java | 18 +
...nkCompactionPerformerWithAlignedSeriesTest.java | 631 +++++++++++++++++++++
.../compaction/utils/CompactionCheckerUtils.java | 8 +-
.../compaction/utils/CompactionTestFileWriter.java | 8 +-
16 files changed, 1611 insertions(+), 23 deletions(-)
copy iotdb-core/datanode/src/{test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTimeseriesType.java => main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/ModifiedStatus.java} (89%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/ReadChunkAlignedSeriesCompactionExecutor.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/loader/ChunkLoader.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/loader/InstantChunkLoader.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/loader/InstantPageLoader.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/readchunk/loader/PageLoader.java
create mode 100644 iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/NewReadChunkCompactionPerformerWithAlignedSeriesTest.java