org.apache.paimon.table

Class RollbackHelper

java.lang.Object

org.apache.paimon.table.RollbackHelper

public class RollbackHelper
extends Object

Helper class for Table.rollbackTo(long) including utils to clean snapshots.

Constructor Summary

Constructors

Constructor and Description
RollbackHelper(SnapshotManager snapshotManager, ChangelogManager changelogManager, TagManager tagManager, FileIO fileIO)

Method Summary

Modifier and Type	Method and Description
void	cleanLargerThan(Snapshot retainedSnapshot) Clean snapshots and tags whose id is larger than given snapshot's and update latest hit.
void	createSnapshotFileIfNeeded(Snapshot taggedSnapshot)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RollbackHelper

public RollbackHelper(SnapshotManager snapshotManager,
                      ChangelogManager changelogManager,
                      TagManager tagManager,
                      FileIO fileIO)

Method Detail

cleanLargerThan

public void cleanLargerThan(Snapshot retainedSnapshot)

Clean snapshots and tags whose id is larger than given snapshot's and update latest hit.

createSnapshotFileIfNeeded

public void createSnapshotFileIfNeeded(Snapshot taggedSnapshot)