org.apache.paimon.flink.source

Class ReaderConsumeProgressEvent

java.lang.Object

org.apache.paimon.flink.source.ReaderConsumeProgressEvent

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.SourceEvent

public class ReaderConsumeProgressEvent
extends Object
implements org.apache.flink.api.connector.source.SourceEvent

Event sent from FileStoreSourceReader to ContinuousFileSplitEnumerator to describe the current consumption progress.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ReaderConsumeProgressEvent(long lastConsumeSnapshotId)

Method Summary

Modifier and Type	Method and Description
long	lastConsumeSnapshotId()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReaderConsumeProgressEvent

public ReaderConsumeProgressEvent(long lastConsumeSnapshotId)

Method Detail

lastConsumeSnapshotId

public long lastConsumeSnapshotId()

toString

public String toString()

Overrides:

toString in class Object