Package org.apache.flink.cdc.connectors.fluss.source.deserializer
-
Interface Summary Interface Description FlussDeserializer<T> A generic deserializer interface for converting FlussScanRecords into output records of typeT. -
Class Summary Class Description FlussRecordDeserializer A CDC-specific implementation ofFlussDeserializerthat converts FlussScanRecords into Flink CDCEvents (DataChangeEvents).