| 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.