Package org.apache.flink.cdc.connectors.fluss.source.event

Class FinishedKvSnapshotConsumeEvent

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.event.FinishedKvSnapshotConsumeEvent

All Implemented Interfaces:

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

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

Reports KV snapshots whose consumption is included in a reader checkpoint.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
FinishedKvSnapshotConsumeEvent(long checkpointId, Set<org.apache.fluss.metadata.TableBucket> tableBuckets)

Method Summary

Modifier and Type	Method	Description
long	getCheckpointId()
Set<org.apache.fluss.metadata.TableBucket>	getTableBuckets()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

FinishedKvSnapshotConsumeEvent

public FinishedKvSnapshotConsumeEvent(long checkpointId,
                                      Set<org.apache.fluss.metadata.TableBucket> tableBuckets)

Method Detail

getCheckpointId

public long getCheckpointId()

getTableBuckets

public Set<org.apache.fluss.metadata.TableBucket> getTableBuckets()

toString

public String toString()

Overrides:

toString in class Object