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

Class FlussSnapshotSplit

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

FlussHybridSnapshotLogSplit

public abstract class FlussSnapshotSplit
extends FlussSplitBase

A split that reads a bounded KV snapshot from a Fluss table bucket. This is the base class for snapshot-based reading and is extended by FlussHybridSnapshotLogSplit to support reading a snapshot followed by change log.

Field Summary

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

rowType, schemaId, tableBucket, tablePath

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FlussSnapshotSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath, org.apache.fluss.metadata.TableBucket tableBucket, long snapshotId, long recordsToSkip, Integer schemaId, org.apache.fluss.types.RowType rowType)	Constructor for snapshot-based split implementations.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
long	getRecordsToSkip()
long	getSnapshotId()
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

FlussSnapshotSplit

protected FlussSnapshotSplit(org.apache.fluss.metadata.PhysicalTablePath tablePath,
                             org.apache.fluss.metadata.TableBucket tableBucket,
                             long snapshotId,
                             long recordsToSkip,
                             @Nullable
                             Integer schemaId,
                             @Nullable
                             org.apache.fluss.types.RowType rowType)

Constructor for snapshot-based split implementations.

Method Detail

getSnapshotId

public long getSnapshotId()

getRecordsToSkip

public long getRecordsToSkip()

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