org.apache.paimon.flink.sink.cdc

Class RichCdcRecord.Builder

java.lang.Object

org.apache.paimon.flink.sink.cdc.RichCdcRecord.Builder

Enclosing class:

RichCdcRecord

public static class RichCdcRecord.Builder
extends Object

Builder for RichCdcRecord.

Constructor Summary

Constructors

Constructor and Description
Builder(RowKind kind, AtomicInteger fieldId)

Method Summary

Modifier and Type	Method and Description
RichCdcRecord	build()
RichCdcRecord.Builder	field(String name, DataType type, String value)
RichCdcRecord.Builder	field(String name, DataType type, String value, String description)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Builder

public Builder(RowKind kind,
               AtomicInteger fieldId)

Method Detail

field

public RichCdcRecord.Builder field(String name,
                                   DataType type,
                                   String value)

field

public RichCdcRecord.Builder field(String name,
                                   DataType type,
                                   String value,
                                   @Nullable
                                   String description)

build

public RichCdcRecord build()