T
- CDC change event type@Experimental public class CdcSinkBuilder<T> extends Object
Constructor and Description |
---|
CdcSinkBuilder() |
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) |
public CdcSinkBuilder<T> withInput(org.apache.flink.streaming.api.datastream.DataStream<T> input)
public CdcSinkBuilder<T> withParserFactory(EventParser.Factory<T> parserFactory)
public CdcSinkBuilder<T> withTable(Table table)
public CdcSinkBuilder<T> withParallelism(@Nullable Integer parallelism)
public CdcSinkBuilder<T> withIdentifier(Identifier identifier)
public CdcSinkBuilder<T> withCatalogLoader(Catalog.Loader catalogLoader)
public org.apache.flink.streaming.api.datastream.DataStreamSink<?> build()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.