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

Class FlussLogSplit

java.lang.Object

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

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

All Implemented Interfaces:

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

public class FlussLogSplit
extends FlussSplitBase

A split that reads change log records from a Fluss table bucket starting at a given offset. This is used for streaming CDC reads (earliest, latest, timestamp startup modes).

Field Summary

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

rowType, schemaId, tableBucket, tablePath

Constructor Summary

Constructors

Constructor	Description
FlussLogSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath, org.apache.fluss.metadata.TableBucket tableBucket, long startingOffset)
FlussLogSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath, org.apache.fluss.metadata.TableBucket tableBucket, long startingOffset, Integer schemaId, org.apache.fluss.types.RowType rowType)	Full constructor, typically used during checkpoint recovery.

Method Summary

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

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

FlussLogSplit

public FlussLogSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath,
                     org.apache.fluss.metadata.TableBucket tableBucket,
                     long startingOffset)

FlussLogSplit

public FlussLogSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath,
                     org.apache.fluss.metadata.TableBucket tableBucket,
                     long startingOffset,
                     @Nullable
                     Integer schemaId,
                     @Nullable
                     org.apache.fluss.types.RowType rowType)

Full constructor, typically used during checkpoint recovery.

Method Detail

getStartingOffset

public long getStartingOffset()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object