org.apache.paimon.flink.sink.cdc

Class RichCdcMultiplexRecord

java.lang.Object

org.apache.paimon.flink.sink.cdc.RichCdcMultiplexRecord

All Implemented Interfaces:

Serializable

public class RichCdcMultiplexRecord
extends Object
implements Serializable

Compared to CdcMultiplexRecord, this contains schema information.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RichCdcMultiplexRecord(String databaseName, String tableName, List<DataField> fields, List<String> primaryKeys, CdcRecord cdcRecord)

Method Summary

Modifier and Type	Method and Description
String	databaseName()
boolean	equals(Object o)
List<DataField>	fields()
int	hashCode()
List<String>	primaryKeys()
String	tableName()
RichCdcRecord	toRichCdcRecord()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

RichCdcMultiplexRecord

public RichCdcMultiplexRecord(@Nullable
                              String databaseName,
                              @Nullable
                              String tableName,
                              List<DataField> fields,
                              List<String> primaryKeys,
                              CdcRecord cdcRecord)

Method Detail

databaseName

@Nullable
public String databaseName()

tableName

@Nullable
public String tableName()

fields

public List<DataField> fields()

primaryKeys

public List<String> primaryKeys()

toRichCdcRecord

public RichCdcRecord toRichCdcRecord()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object