Package org.apache.flink.cdc.connectors.fluss.sink
-
Class Summary Class Description FlussDataSink A DataSink implementation for Fluss.FlussDataSinkOptions Options forFlussDataSink.FlussEventSerializationSchema Serialization schema that converts a CDC data record to a Fluss event.FlussHashFunctionProvider HashFunctionProviderimplementation forFlussDataSink.FlussMetaDataApplier MetadataApplierfor fluss. -
Enum Summary Enum Description FlussDataSinkOptions.SinkPartitioningStrategy The shuffle strategy for fluss sink.