org.apache.paimon.table

Class ExpireSnapshotsImpl

java.lang.Object

org.apache.paimon.table.ExpireSnapshotsImpl

All Implemented Interfaces:

ExpireSnapshots

public class ExpireSnapshotsImpl
extends Object
implements ExpireSnapshots

An implementation for ExpireSnapshots.

Constructor Summary

Constructors

Constructor and Description
ExpireSnapshotsImpl(SnapshotManager snapshotManager, SnapshotDeletion snapshotDeletion, TagManager tagManager)

Method Summary

Modifier and Type	Method and Description
ExpireSnapshots	config(ExpireConfig expireConfig)
int	expire()
int	expireUntil(long earliestId, long endExclusiveId)
static List<Snapshot>	findSkippingTags(List<Snapshot> sortedTags, long beginInclusive, long endExclusive) Find the skipping tags in sortedTags for range of [beginInclusive, endExclusive).
SnapshotDeletion	snapshotDeletion()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExpireSnapshotsImpl

public ExpireSnapshotsImpl(SnapshotManager snapshotManager,
                           SnapshotDeletion snapshotDeletion,
                           TagManager tagManager)

Method Detail

config

public ExpireSnapshots config(ExpireConfig expireConfig)

Specified by:

config in interface ExpireSnapshots

expire

public int expire()

Specified by:

expire in interface ExpireSnapshots

Returns:

How many snapshots have been expired.

expireUntil

@VisibleForTesting
public int expireUntil(long earliestId,
                                          long endExclusiveId)

snapshotDeletion

@VisibleForTesting
public SnapshotDeletion snapshotDeletion()

findSkippingTags

public static List<Snapshot> findSkippingTags(List<Snapshot> sortedTags,
                                              long beginInclusive,
                                              long endExclusive)

Find the skipping tags in sortedTags for range of [beginInclusive, endExclusive).