org.apache.paimon.table.source.snapshot

Class TimeTravelUtil

java.lang.Object

org.apache.paimon.table.source.snapshot.TimeTravelUtil

public class TimeTravelUtil
extends Object

The util class of resolve snapshot from scan params for time travel.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TimeTravelUtil.InconsistentTagBucketException Exception thrown when the bucket number of two tags are different in incremental tag query.

Constructor Summary

Constructors

Constructor and Description
TimeTravelUtil()

Method Summary

Modifier and Type	Method and Description
static void	checkRescaleBucketForIncrementalDiffQuery(SchemaManager schemaManager, Snapshot start, Snapshot end)
static Long	earlierThanTimeMills(SnapshotManager snapshotManager, ChangelogManager changelogManager, long timestampMills, boolean startFromChangelog, boolean returnNullIfTooEarly) Returns the latest snapshot earlier than the timestamp mills.
static Snapshot	tryTravelOrLatest(FileStoreTable table)
static Optional<Snapshot>	tryTravelToSnapshot(FileStoreTable table)
static Optional<Snapshot>	tryTravelToSnapshot(Options options, SnapshotManager snapshotManager, TagManager tagManager)

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeTravelUtil

public TimeTravelUtil()

Method Detail

tryTravelOrLatest

public static Snapshot tryTravelOrLatest(FileStoreTable table)

tryTravelToSnapshot

public static Optional<Snapshot> tryTravelToSnapshot(FileStoreTable table)

tryTravelToSnapshot

public static Optional<Snapshot> tryTravelToSnapshot(Options options,
                                                     SnapshotManager snapshotManager,
                                                     TagManager tagManager)

earlierThanTimeMills

@Nullable
public static Long earlierThanTimeMills(SnapshotManager snapshotManager,
                                                  ChangelogManager changelogManager,
                                                  long timestampMills,
                                                  boolean startFromChangelog,
                                                  boolean returnNullIfTooEarly)

Returns the latest snapshot earlier than the timestamp mills. A non-existent snapshot may be returned if all snapshots are equal to or later than the timestamp mills.

checkRescaleBucketForIncrementalDiffQuery

public static void checkRescaleBucketForIncrementalDiffQuery(SchemaManager schemaManager,
                                                             Snapshot start,
                                                             Snapshot end)