Uses of Class
org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder

Packages that use RichCdcSinkBuilder

Package	Description
org.apache.paimon.flink.sink.cdc

Uses of RichCdcSinkBuilder in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc that return RichCdcSinkBuilder

Modifier and Type	Method and Description
RichCdcSinkBuilder	RichCdcSinkBuilder.catalogLoader(Catalog.Loader catalogLoader)
RichCdcSinkBuilder	RichCdcSinkBuilder.forRichCdcRecord(org.apache.flink.streaming.api.datastream.DataStream<RichCdcRecord> input)
RichCdcSinkBuilder	RichCdcSinkBuilder.identifier(Identifier identifier)
RichCdcSinkBuilder	RichCdcSinkBuilder.parallelism(Integer parallelism)
RichCdcSinkBuilder	RichCdcSinkBuilder.withCatalogLoader(Catalog.Loader catalogLoader) Deprecated. Use catalogLoader.
RichCdcSinkBuilder	RichCdcSinkBuilder.withIdentifier(Identifier identifier) Deprecated. Use identifier.
RichCdcSinkBuilder	RichCdcSinkBuilder.withInput(org.apache.flink.streaming.api.datastream.DataStream<RichCdcRecord> input) Deprecated. Use forRichCdcRecord(org.apache.flink.streaming.api.datastream.DataStream<org.apache.paimon.flink.sink.cdc.RichCdcRecord>).
RichCdcSinkBuilder	RichCdcSinkBuilder.withParallelism(Integer parallelism) Deprecated. Use parallelism.
RichCdcSinkBuilder	RichCdcSinkBuilder.withTable(Table table) Deprecated. Use constructor to pass Table.