Class Hierarchy
- java.lang.Object
- org.apache.flink.cdc.connectors.fluss.sink.FlussDataSink (implements org.apache.flink.cdc.common.sink.DataSink)
- org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions
- org.apache.flink.cdc.connectors.fluss.sink.FlussEventSerializationSchema (implements org.apache.flink.cdc.connectors.fluss.sink.v2.FlussEventSerializer<InputT>)
- org.apache.flink.cdc.connectors.fluss.sink.FlussHashFunctionProvider (implements org.apache.flink.cdc.common.function.HashFunctionProvider<T>)
- org.apache.flink.cdc.connectors.fluss.sink.FlussMetaDataApplier (implements org.apache.flink.cdc.common.sink.ExistingTableSchemaExpansionSupport, org.apache.flink.cdc.common.sink.MetadataApplier)
Enum Hierarchy
- java.lang.Object
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
- org.apache.flink.cdc.connectors.fluss.sink.FlussDataSinkOptions.SinkPartitioningStrategy
- java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)