Package org.apache.flink.cdc.connectors.paimon.sink
-
Class Summary Class Description PaimonDataSink ADataSinkfor Paimon connector that supports schema evolution.PaimonDataSinkFactory ADataSinkFactoryto createPaimonDataSink.PaimonDataSinkOptions copy fromCatalogOptions.PaimonHashFunction AHashFunctionimplementation forPaimonDataSink.PaimonHashFunctionProvider AHashFunctionProviderimplementation forPaimonDataSink.PaimonMetadataApplier AMetadataApplierthat applies metadata changes to Paimon.SchemaChangeProvider The SchemaChangeProvider class provides static methods to create SchemaChange objects that represent different types of schema modifications.