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

Class FlussSource<T>

java.lang.Object

org.apache.flink.cdc.connectors.fluss.source.FlussSource<T>

Type Parameters:

T - The type of output records produced by this source.

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<T,FlussSplitBase,FlussSourceEnumState>, org.apache.flink.api.connector.source.SourceReaderFactory<T,FlussSplitBase>

public class FlussSource<T>
extends Object
implements org.apache.flink.api.connector.source.Source<T,FlussSplitBase,FlussSourceEnumState>

A generic Flink Source implementation for reading records from Fluss tables. This source is continuous and unbounded, reading change log records from the Fluss log store.

The output type T is determined by the provided FlussDeserializer, making this source reusable for different output types. The CDC-specific binding (e.g., producing Event objects) is done at the FlussDataSource layer.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlussSource(TableDiscoverer discoverer, org.apache.fluss.config.Configuration flussConfig, Configuration sourceConfig, org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer, long scanDiscoveryIntervalMs, FlussDeserializer<T> deserializer)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SplitEnumerator<FlussSplitBase,FlussSourceEnumState>	createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FlussSplitBase> enumContext)
org.apache.flink.api.connector.source.SourceReader<T,FlussSplitBase>	createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
org.apache.flink.api.connector.source.Boundedness	getBoundedness()
org.apache.flink.core.io.SimpleVersionedSerializer<FlussSourceEnumState>	getEnumeratorCheckpointSerializer()
org.apache.flink.core.io.SimpleVersionedSerializer<FlussSplitBase>	getSplitSerializer()
org.apache.flink.api.connector.source.SplitEnumerator<FlussSplitBase,FlussSourceEnumState>	restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FlussSplitBase> enumContext, FlussSourceEnumState checkpoint)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlussSource

public FlussSource(TableDiscoverer discoverer,
                   org.apache.fluss.config.Configuration flussConfig,
                   Configuration sourceConfig,
                   org.apache.fluss.client.initializer.OffsetsInitializer offsetsInitializer,
                   long scanDiscoveryIntervalMs,
                   FlussDeserializer<T> deserializer)

Method Detail

getBoundedness

public org.apache.flink.api.connector.source.Boundedness getBoundedness()

Specified by:

getBoundedness in interface org.apache.flink.api.connector.source.Source<T,FlussSplitBase,FlussSourceEnumState>

createEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<FlussSplitBase,FlussSourceEnumState> createEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FlussSplitBase> enumContext)

Specified by:

createEnumerator in interface org.apache.flink.api.connector.source.Source<T,FlussSplitBase,FlussSourceEnumState>

restoreEnumerator

public org.apache.flink.api.connector.source.SplitEnumerator<FlussSplitBase,FlussSourceEnumState> restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext<FlussSplitBase> enumContext,
                                                                                                                          FlussSourceEnumState checkpoint)

Specified by:

restoreEnumerator in interface org.apache.flink.api.connector.source.Source<T,FlussSplitBase,FlussSourceEnumState>

getSplitSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<FlussSplitBase> getSplitSerializer()

Specified by:

getSplitSerializer in interface org.apache.flink.api.connector.source.Source<T,FlussSplitBase,FlussSourceEnumState>

getEnumeratorCheckpointSerializer

public org.apache.flink.core.io.SimpleVersionedSerializer<FlussSourceEnumState> getEnumeratorCheckpointSerializer()

Specified by:

getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<T,FlussSplitBase,FlussSourceEnumState>

createReader

public org.apache.flink.api.connector.source.SourceReader<T,FlussSplitBase> createReader(org.apache.flink.api.connector.source.SourceReaderContext readerContext)

Specified by:

createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<T,FlussSplitBase>