CdcSinkBuilder<T> |
CdcSinkBuilder.withCatalogLoader(CatalogLoader 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) |
CdcSinkBuilder<T> |
CdcSinkBuilder.withTypeMapping(TypeMapping typeMapping) |