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

Class FlussSplitBase

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

FlussLogSplit, FlussSnapshotSplit

public abstract class FlussSplitBase
extends Object
implements org.apache.flink.api.connector.source.SourceSplit

Abstract base class for all Fluss source splits. Each split corresponds to a single bucket of a single table, optionally within a specific partition.

Concrete subclasses include:

• FlussLogSplit: reads change log records from a starting offset.
• FlussSnapshotSplit: reads a bounded KV snapshot.
• FlussHybridSnapshotLogSplit: first reads a KV snapshot, then switches to reading change log from the snapshot's log offset.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.fluss.types.RowType	rowType	The RowType corresponding to schemaId.
protected Integer	schemaId	The schema ID of the last record processed by this split.
protected org.apache.fluss.metadata.TableBucket	tableBucket
protected org.apache.fluss.metadata.PhysicalTablePath	tablePath

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FlussSplitBase(org.apache.fluss.metadata.PhysicalTablePath tablePath, org.apache.fluss.metadata.TableBucket tableBucket)
protected	FlussSplitBase(org.apache.fluss.metadata.PhysicalTablePath tablePath, org.apache.fluss.metadata.TableBucket tableBucket, Integer schemaId, org.apache.fluss.types.RowType rowType)

Method Summary

Modifier and Type	Method	Description
FlussHybridSnapshotLogSplit	asHybridSnapshotLogSplit()
FlussLogSplit	asLogSplit()
FlussSnapshotSplit	asSnapshotSplit()
org.apache.fluss.metadata.PhysicalTablePath	getPhysicalTablePath()
org.apache.fluss.types.RowType	getRowType()
Integer	getSchemaId()
org.apache.fluss.metadata.TableBucket	getTableBucket()
org.apache.fluss.metadata.TablePath	getTablePath()	Convenience method returning the logical TablePath (database + table name).
boolean	isHybridSnapshotLogSplit()
boolean	isLogSplit()
boolean	isSnapshotSplit()
String	splitId()

Methods inherited from class java.lang.Object

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

Field Detail

tablePath

protected final org.apache.fluss.metadata.PhysicalTablePath tablePath

tableBucket

protected final org.apache.fluss.metadata.TableBucket tableBucket

schemaId

@Nullable
protected final Integer schemaId

The schema ID of the last record processed by this split. null when created by the enumerator (unknown until records are read).

rowType

@Nullable
protected final org.apache.fluss.types.RowType rowType

The RowType corresponding to schemaId. Used to restore the deserializer's schema cache on recovery.

Constructor Detail

FlussSplitBase

protected FlussSplitBase(org.apache.fluss.metadata.PhysicalTablePath tablePath,
                         org.apache.fluss.metadata.TableBucket tableBucket)

FlussSplitBase

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

Method Detail

splitId

public String splitId()

Specified by:

splitId in interface org.apache.flink.api.connector.source.SourceSplit

getPhysicalTablePath

public org.apache.fluss.metadata.PhysicalTablePath getPhysicalTablePath()

getTablePath

public org.apache.fluss.metadata.TablePath getTablePath()

Convenience method returning the logical TablePath (database + table name).

getTableBucket

public org.apache.fluss.metadata.TableBucket getTableBucket()

getSchemaId

@Nullable
public Integer getSchemaId()

getRowType

@Nullable
public org.apache.fluss.types.RowType getRowType()

isLogSplit

public boolean isLogSplit()

isSnapshotSplit

public boolean isSnapshotSplit()

isHybridSnapshotLogSplit

public boolean isHybridSnapshotLogSplit()

asLogSplit

public FlussLogSplit asLogSplit()

asSnapshotSplit

public FlussSnapshotSplit asSnapshotSplit()

asHybridSnapshotLogSplit

public FlussHybridSnapshotLogSplit asHybridSnapshotLogSplit()