org.apache.paimon.flink.sink.cdc

Class RichCdcSinkBuilder

java.lang.Object

org.apache.paimon.flink.sink.cdc.RichCdcSinkBuilder

@Public
public class RichCdcSinkBuilder
extends Object

DataStream API for building Flink Sink for RichCdcRecord to write with schema evolution.

Since:

0.8

Constructor Summary

Constructors

Constructor and Description
RichCdcSinkBuilder() Deprecated. Use constructor to pass table.
RichCdcSinkBuilder(Table table)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	build()
RichCdcSinkBuilder	catalogLoader(Catalog.Loader catalogLoader)
RichCdcSinkBuilder	forRichCdcRecord(org.apache.flink.streaming.api.datastream.DataStream<RichCdcRecord> input)
RichCdcSinkBuilder	identifier(Identifier identifier)
RichCdcSinkBuilder	parallelism(Integer parallelism)
RichCdcSinkBuilder	withCatalogLoader(Catalog.Loader catalogLoader) Deprecated. Use catalogLoader.
RichCdcSinkBuilder	withIdentifier(Identifier identifier) Deprecated. Use identifier.
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	withParallelism(Integer parallelism) Deprecated. Use parallelism.
RichCdcSinkBuilder	withTable(Table table) Deprecated. Use constructor to pass Table.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RichCdcSinkBuilder

public RichCdcSinkBuilder(Table table)

RichCdcSinkBuilder

@Deprecated
public RichCdcSinkBuilder()

Deprecated. Use constructor to pass table.

Method Detail

forRichCdcRecord

public RichCdcSinkBuilder forRichCdcRecord(org.apache.flink.streaming.api.datastream.DataStream<RichCdcRecord> input)

identifier

public RichCdcSinkBuilder identifier(Identifier identifier)

parallelism

public RichCdcSinkBuilder parallelism(@Nullable
                                      Integer parallelism)

catalogLoader

public RichCdcSinkBuilder catalogLoader(Catalog.Loader catalogLoader)

build

public org.apache.flink.streaming.api.datastream.DataStreamSink<?> build()

withInput

@Deprecated
public 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>).

withTable

@Deprecated
public RichCdcSinkBuilder withTable(Table table)

Deprecated. Use constructor to pass Table.

withParallelism

@Deprecated
public RichCdcSinkBuilder withParallelism(@Nullable
                                                      Integer parallelism)

Deprecated. Use parallelism.

withIdentifier

@Deprecated
public RichCdcSinkBuilder withIdentifier(Identifier identifier)

Deprecated. Use identifier.

withCatalogLoader

@Deprecated
public RichCdcSinkBuilder withCatalogLoader(Catalog.Loader catalogLoader)

Deprecated. Use catalogLoader.