This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
from 85f1cfd2e [core] Add limitation to the buffer spill disk usage (#3108)
add 46609f27f [core] Introduce ExpireChangelogImpl to decouple the
changelog lifecycle (#3110)
No new revisions were added by this update.
Summary of changes:
.../shortcodes/generated/core_configuration.html | 18 +++
.../main/java/org/apache/paimon/CoreOptions.java | 41 +++++
.../src/main/java/org/apache/paimon/Changelog.java | 131 ++++++++++++++++
.../src/main/java/org/apache/paimon/Snapshot.java | 38 ++---
.../apache/paimon/operation/FileDeletionBase.java | 68 ++++----
.../apache/paimon/operation/SnapshotDeletion.java | 7 +-
.../org/apache/paimon/schema/SchemaValidation.java | 11 ++
.../paimon/table/AbstractFileStoreTable.java | 28 +++-
.../apache/paimon/table/ExpireChangelogImpl.java | 172 +++++++++++++++++++++
.../apache/paimon/table/ExpireSnapshotsImpl.java | 83 ++++++++--
.../org/apache/paimon/table/ReadonlyTable.java | 8 +
.../org/apache/paimon/table/RollbackHelper.java | 43 ++++++
.../main/java/org/apache/paimon/table/Table.java | 3 +
.../table/source/AbstractInnerTableScan.java | 16 +-
.../table/source/InnerStreamTableScanImpl.java | 24 ++-
.../ContinuousFromSnapshotStartingScanner.java | 31 +++-
.../ContinuousFromTimestampStartingScanner.java | 13 +-
.../apache/paimon/utils/NextSnapshotFetcher.java | 74 +++++++++
.../org/apache/paimon/utils/SnapshotManager.java | 140 +++++++++++++----
.../test/java/org/apache/paimon/TestFileStore.java | 118 +++++++++++++-
.../paimon/operation/ExpireSnapshotsTest.java | 35 +++++
.../apache/paimon/operation/FileDeletionTest.java | 1 +
.../paimon/table/FileStoreTableTestBase.java | 6 +
.../paimon/table/source/StartupModeTest.java | 4 +-
.../apache/paimon/table/source/TableScanTest.java | 2 +-
...ContinuousFromTimestampStartingScannerTest.java | 81 +++++++++-
.../table/source/snapshot/ScannerTestBase.java | 12 +-
.../apache/paimon/utils/SnapshotManagerTest.java | 49 +++++-
.../paimon/flink/ContinuousFileStoreITCase.java | 42 +++++
29 files changed, 1152 insertions(+), 147 deletions(-)
create mode 100644 paimon-core/src/main/java/org/apache/paimon/Changelog.java
create mode 100644
paimon-core/src/main/java/org/apache/paimon/table/ExpireChangelogImpl.java
create mode 100644
paimon-core/src/main/java/org/apache/paimon/utils/NextSnapshotFetcher.java
