Uses of Package
org.apache.flink.cdc.connectors.fluss.source.reader
-
Classes in org.apache.flink.cdc.connectors.fluss.source.reader used by org.apache.flink.cdc.connectors.fluss.source.deserializer Class Description FlussSourceRecord A wrapper that bundles a FlussScanRecordtogether with the table context (table path and row type) needed for deserialization. -
Classes in org.apache.flink.cdc.connectors.fluss.source.reader used by org.apache.flink.cdc.connectors.fluss.source.enumerator Class Description LeaseContext Context for a Fluss KV snapshot lease. -
Classes in org.apache.flink.cdc.connectors.fluss.source.reader used by org.apache.flink.cdc.connectors.fluss.source.reader Class Description FlussRecordEmitter FlussSourceRecord A wrapper that bundles a FlussScanRecordtogether with the table context (table path and row type) needed for deserialization.LeaseContext Context for a Fluss KV snapshot lease.