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

Class Summary

Class	Description
FlussDataSource	A CDC-specific DataSource implementation for Fluss.
FlussDataSourceOptions	Options for Fluss DataSource.
FlussMetadataAccessor	A MetadataAccessor implementation that uses the Fluss Admin API to list databases, tables, and retrieve table schemas from a Fluss cluster.
FlussSource<T>	A generic Flink Source implementation for reading records from Fluss tables.