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

Class FlussHybridSnapshotLogSplit

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.split.FlussSplitBase

org.apache.flink.cdc.connectors.fluss.source.split.FlussSnapshotSplit

org.apache.flink.cdc.connectors.fluss.source.split.FlussHybridSnapshotLogSplit

All Implemented Interfaces:

org.apache.flink.api.connector.source.SourceSplit

public class FlussHybridSnapshotLogSplit
extends FlussSnapshotSplit

A split that first reads a full KV snapshot from a Fluss table bucket, then switches to reading change log from the snapshot's log offset. This is used by the "full" startup mode for primary key tables.

Extends FlussSnapshotSplit with additional log-reading state: the log starting offset and whether the snapshot phase is already finished (used for checkpoint recovery).

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.fluss.source.split.FlussSplitBase

rowType, schemaId, tableBucket, tablePath

Constructor Summary

Constructors

Constructor	Description
FlussHybridSnapshotLogSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath, org.apache.fluss.metadata.TableBucket tableBucket, long snapshotId, long logStartingOffset)	Creates a new hybrid split with snapshot not yet finished.
FlussHybridSnapshotLogSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath, org.apache.fluss.metadata.TableBucket tableBucket, long snapshotId, long recordsToSkip, long logStartingOffset, boolean snapshotFinished, Integer schemaId, org.apache.fluss.types.RowType rowType)	Full constructor with schema info, typically used during checkpoint recovery.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
long	getLogStartingOffset()
int	hashCode()
boolean	isSnapshotFinished()
String	toString()

Methods inherited from class org.apache.flink.cdc.connectors.fluss.source.split.FlussSnapshotSplit

getRecordsToSkip, getSnapshotId

Methods inherited from class org.apache.flink.cdc.connectors.fluss.source.split.FlussSplitBase

asHybridSnapshotLogSplit, asLogSplit, asSnapshotSplit, getPhysicalTablePath, getRowType, getSchemaId, getTableBucket, getTablePath, isHybridSnapshotLogSplit, isLogSplit, isSnapshotSplit, splitId

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

FlussHybridSnapshotLogSplit

public FlussHybridSnapshotLogSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath,
                                   org.apache.fluss.metadata.TableBucket tableBucket,
                                   long snapshotId,
                                   long logStartingOffset)

Creates a new hybrid split with snapshot not yet finished.

FlussHybridSnapshotLogSplit

public FlussHybridSnapshotLogSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath,
                                   org.apache.fluss.metadata.TableBucket tableBucket,
                                   long snapshotId,
                                   long recordsToSkip,
                                   long logStartingOffset,
                                   boolean snapshotFinished,
                                   @Nullable
                                   Integer schemaId,
                                   @Nullable
                                   org.apache.fluss.types.RowType rowType)

Full constructor with schema info, typically used during checkpoint recovery.

Method Detail

getLogStartingOffset

public long getLogStartingOffset()

isSnapshotFinished

public boolean isSnapshotFinished()

equals

public boolean equals(Object o)

Overrides:

equals in class FlussSnapshotSplit

hashCode

public int hashCode()

Overrides:

hashCode in class FlussSnapshotSplit

toString

public String toString()

Overrides:

toString in class FlussSnapshotSplit