org.apache.paimon.utils

Class ChangelogManager

java.lang.Object

org.apache.paimon.utils.ChangelogManager

All Implemented Interfaces:

Serializable

public class ChangelogManager
extends Object
implements Serializable

Manager for Changelog, providing utility methods related to paths and changelog hints.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHANGELOG_PREFIX

Constructor Summary

Constructors

Constructor and Description
ChangelogManager(FileIO fileIO, Path tablePath, String branchName)

Method Summary

Modifier and Type	Method and Description
Changelog	changelog(long snapshotId)
Path	changelogDirectory()
Iterator<Changelog>	changelogs()
void	commitChangelog(Changelog changelog, long id)
void	commitLongLivedChangelogEarliestHint(long snapshotId)
void	commitLongLivedChangelogLatestHint(long snapshotId)
Long	earliestLongLivedChangelogId()
FileIO	fileIO()
Long	latestLongLivedChangelogId()
Changelog	longLivedChangelog(long snapshotId)
boolean	longLivedChangelogExists(long snapshotId)
Path	longLivedChangelogPath(long snapshotId)
List<Changelog>	safelyGetAllChangelogs()
Changelog	tryGetChangelog(long snapshotId)

Methods inherited from class java.lang.Object

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

Field Detail

CHANGELOG_PREFIX

public static final String CHANGELOG_PREFIX

See Also:

Constant Field Values

Constructor Detail

ChangelogManager

public ChangelogManager(FileIO fileIO,
                        Path tablePath,
                        @Nullable
                        String branchName)

Method Detail

fileIO

public FileIO fileIO()

latestLongLivedChangelogId

@Nullable
public Long latestLongLivedChangelogId()

earliestLongLivedChangelogId

@Nullable
public Long earliestLongLivedChangelogId()

longLivedChangelogExists

public boolean longLivedChangelogExists(long snapshotId)

longLivedChangelog

public Changelog longLivedChangelog(long snapshotId)

changelog

public Changelog changelog(long snapshotId)

longLivedChangelogPath

public Path longLivedChangelogPath(long snapshotId)

changelogDirectory

public Path changelogDirectory()

commitChangelog

public void commitChangelog(Changelog changelog,
                            long id)
                     throws IOException

Throws:

IOException

commitLongLivedChangelogLatestHint

public void commitLongLivedChangelogLatestHint(long snapshotId)
                                        throws IOException

Throws:

IOException

commitLongLivedChangelogEarliestHint

public void commitLongLivedChangelogEarliestHint(long snapshotId)
                                          throws IOException

Throws:

IOException

tryGetChangelog

public Changelog tryGetChangelog(long snapshotId)
                          throws FileNotFoundException

Throws:

FileNotFoundException

changelogs

public Iterator<Changelog> changelogs()
                               throws IOException

Throws:

IOException

safelyGetAllChangelogs

public List<Changelog> safelyGetAllChangelogs()
                                       throws IOException

Throws:

IOException