org.apache.flink.cdc.connectors.fluss.sink.v2 (flink-cdc-parent 3.8-SNAPSHOT API)

Interface Summary
Interface Description

FlussEventSerializer<InputT>
Serializer to serialize the input record to a FlussEvent for FlussSinkWriter.

Class Summary
Class	Description
FlussEvent	FlussEvent is a wrapper for a list of genericRows.
FlussRowWithOp	A wrapper class that associates an `InternalRow` with an `FlussOperationType` for use in Fluss-Flink data processing.
FlussSink<InputT>	Flink sink for Fluss.
FlussSinkWriter<InputT>	Base class for Flink `SinkWriter` implementations in Fluss.

Enum Summary
Enum Description

FlussOperationType
Enumeration of row operation types used in Fluss-Flink data processing.