Package | Description |
---|---|
org.apache.paimon.flink.sink.cdc |
Modifier and Type | Method and Description |
---|---|
RichCdcRecord |
RichCdcRecord.Builder.build() |
RichCdcRecord |
RichCdcMultiplexRecord.toRichCdcRecord() |
Modifier and Type | Method and Description |
---|---|
void |
RichEventParser.setRawEvent(RichCdcRecord rawEvent) |
Modifier and Type | Method and Description |
---|---|
RichCdcSinkBuilder |
RichCdcSinkBuilder.forRichCdcRecord(org.apache.flink.streaming.api.datastream.DataStream<RichCdcRecord> input) |
RichCdcSinkBuilder |
RichCdcSinkBuilder.withInput(org.apache.flink.streaming.api.datastream.DataStream<RichCdcRecord> input)
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.