Package | Description |
---|---|
org.apache.paimon.flink.sink.cdc |
Modifier and Type | Method and Description |
---|---|
CdcSinkBuilder<T> |
CdcSinkBuilder.withCatalogLoader(Catalog.Loader catalogLoader) |
CdcSinkBuilder<T> |
CdcSinkBuilder.withIdentifier(Identifier identifier) |
CdcSinkBuilder<T> |
CdcSinkBuilder.withInput(org.apache.flink.streaming.api.datastream.DataStream<T> input) |
CdcSinkBuilder<T> |
CdcSinkBuilder.withParallelism(Integer parallelism) |
CdcSinkBuilder<T> |
CdcSinkBuilder.withParserFactory(EventParser.Factory<T> parserFactory) |
CdcSinkBuilder<T> |
CdcSinkBuilder.withTable(Table table) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.