org.apache.paimon.table

Class ExpireChangelogImpl

java.lang.Object

org.apache.paimon.table.ExpireChangelogImpl

All Implemented Interfaces:

ExpireSnapshots

public class ExpireChangelogImpl
extends Object
implements ExpireSnapshots

Cleanup the changelog in changelog directory.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
ExpireChangelogImpl(SnapshotManager snapshotManager, ChangelogManager changelogManager, TagManager tagManager, ChangelogDeletion changelogDeletion)

Method Summary

Modifier and Type	Method and Description
ExpireSnapshots	config(ExpireConfig expireConfig)
int	expire()
void	expireAll() expire all separated changelogs, only used by ExpireChangelogsProcedure.
int	expireUntil(long earliestId, long endExclusiveId)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Constructor Detail

ExpireChangelogImpl

public ExpireChangelogImpl(SnapshotManager snapshotManager,
                           ChangelogManager changelogManager,
                           TagManager tagManager,
                           ChangelogDeletion changelogDeletion)

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

public int expireUntil(long earliestId,
                       long endExclusiveId)

expireAll

public void expireAll()

expire all separated changelogs, only used by ExpireChangelogsProcedure.