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

Class Summary

Class	Description
FlussRecordEmitter<T>	A RecordEmitter that uses a FlussDeserializer to convert FlussSourceRecords into the output type T.
FlussSourceReader<T>	A generic SourceReader for Fluss, built on top of Flink's SingleThreadMultiplexSourceReaderBase.
FlussSourceRecord	A wrapper that bundles a Fluss ScanRecord together with the table context (table path and row type) needed for deserialization.
FlussSplitReader	A SplitReader implementation for Fluss.
LeaseContext	Context for a Fluss KV snapshot lease.