org.apache.paimon.flink.sink.cdc

Class CdcSinkBuilder<T>

java.lang.Object

org.apache.paimon.flink.sink.cdc.CdcSinkBuilder<T>

Type Parameters:

T - CDC change event type

@Experimental
public class CdcSinkBuilder<T>
extends Object

Builder for sink when syncing records into one Paimon table.

Constructor Summary

Constructors

Constructor and Description
CdcSinkBuilder()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.api.datastream.DataStreamSink<?>	build()
CdcSinkBuilder<T>	withCatalogLoader(Catalog.Loader catalogLoader)
CdcSinkBuilder<T>	withIdentifier(Identifier identifier)
CdcSinkBuilder<T>	withInput(org.apache.flink.streaming.api.datastream.DataStream<T> input)
CdcSinkBuilder<T>	withParallelism(Integer parallelism)
CdcSinkBuilder<T>	withParserFactory(EventParser.Factory<T> parserFactory)
CdcSinkBuilder<T>	withTable(Table table)

Methods inherited from class java.lang.Object

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

Constructor Detail

CdcSinkBuilder

public CdcSinkBuilder()

Method Detail

withInput

public CdcSinkBuilder<T> withInput(org.apache.flink.streaming.api.datastream.DataStream<T> input)

withParserFactory

public CdcSinkBuilder<T> withParserFactory(EventParser.Factory<T> parserFactory)

withTable

public CdcSinkBuilder<T> withTable(Table table)

withParallelism

public CdcSinkBuilder<T> withParallelism(@Nullable
                                         Integer parallelism)

withIdentifier

public CdcSinkBuilder<T> withIdentifier(Identifier identifier)

withCatalogLoader

public CdcSinkBuilder<T> withCatalogLoader(Catalog.Loader catalogLoader)

build

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