@Public public class RichCdcSinkBuilder extends Object
RichCdcRecord
to write with schema evolution.Constructor and Description |
---|
RichCdcSinkBuilder()
Deprecated.
Use constructor to pass table.
|
RichCdcSinkBuilder(Table table) |
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)
|
RichCdcSinkBuilder |
withParallelism(Integer parallelism)
Deprecated.
Use
parallelism . |
RichCdcSinkBuilder |
withTable(Table table)
Deprecated.
Use constructor to pass Table.
|
public RichCdcSinkBuilder(Table table)
@Deprecated public RichCdcSinkBuilder()
public RichCdcSinkBuilder forRichCdcRecord(org.apache.flink.streaming.api.datastream.DataStream<RichCdcRecord> input)
public RichCdcSinkBuilder identifier(Identifier identifier)
public RichCdcSinkBuilder parallelism(@Nullable Integer parallelism)
public RichCdcSinkBuilder catalogLoader(Catalog.Loader catalogLoader)
public org.apache.flink.streaming.api.datastream.DataStreamSink<?> build()
@Deprecated public RichCdcSinkBuilder withInput(org.apache.flink.streaming.api.datastream.DataStream<RichCdcRecord> input)
@Deprecated public RichCdcSinkBuilder withTable(Table table)
@Deprecated public RichCdcSinkBuilder withParallelism(@Nullable Integer parallelism)
parallelism
.@Deprecated public RichCdcSinkBuilder withIdentifier(Identifier identifier)
identifier
.@Deprecated public RichCdcSinkBuilder withCatalogLoader(Catalog.Loader catalogLoader)
catalogLoader
.Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.