org.apache.paimon.flink.source

Class PendingSplitsCheckpoint

java.lang.Object

org.apache.paimon.flink.source.PendingSplitsCheckpoint

public class PendingSplitsCheckpoint
extends Object

A checkpoint of the current state of the containing the currently pending splits that are not yet assigned.

Constructor Summary

Constructors

Constructor and Description
PendingSplitsCheckpoint(Collection<FileStoreSourceSplit> splits, Long currentSnapshotId)

Method Summary

Modifier and Type	Method and Description
Long	currentSnapshotId()
Collection<FileStoreSourceSplit>	splits()

Methods inherited from class java.lang.Object

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

Constructor Detail

PendingSplitsCheckpoint

public PendingSplitsCheckpoint(Collection<FileStoreSourceSplit> splits,
                               @Nullable
                               Long currentSnapshotId)

Method Detail

splits

public Collection<FileStoreSourceSplit> splits()

currentSnapshotId

@Nullable
public Long currentSnapshotId()