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	checkRescaleBucketForIncrementalTagQuery(SchemaManager schemaManager, Snapshot start, Snapshot end)
static Snapshot	resolveSnapshot(FileStoreTable table)
static Snapshot	resolveSnapshotFromOptions(CoreOptions options, SnapshotManager snapshotManager)

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

resolveSnapshot

public static Snapshot resolveSnapshot(FileStoreTable table)

resolveSnapshotFromOptions

public static Snapshot resolveSnapshotFromOptions(CoreOptions options,
                                                  SnapshotManager snapshotManager)

checkRescaleBucketForIncrementalTagQuery

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