org.apache.paimon.flink.sink.cdc

Class RichEventParser

java.lang.Object

org.apache.paimon.flink.sink.cdc.RichEventParser

All Implemented Interfaces:

EventParser<RichCdcRecord>

public class RichEventParser
extends Object
implements EventParser<RichCdcRecord>

A EventParser for RichCdcRecord.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.flink.sink.cdc.EventParser

EventParser.Factory<T>

Constructor Summary

Constructors

Constructor and Description
RichEventParser()

Method Summary

Modifier and Type	Method and Description
List<CdcRecord>	parseRecords() Parse records from event.
List<DataField>	parseSchemaChange() Parse new schema if this event contains schema change.
void	setRawEvent(RichCdcRecord rawEvent) Set current raw event to the parser.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.flink.sink.cdc.EventParser

parseNewTable, parseTableName

Constructor Detail

RichEventParser

public RichEventParser()

Method Detail

setRawEvent

public void setRawEvent(RichCdcRecord rawEvent)

Description copied from interface: EventParser

Set current raw event to the parser.

Specified by:

setRawEvent in interface EventParser<RichCdcRecord>

parseSchemaChange

public List<DataField> parseSchemaChange()

Description copied from interface: EventParser

Parse new schema if this event contains schema change.

Specified by:

parseSchemaChange in interface EventParser<RichCdcRecord>

Returns:

empty if there is no schema change

parseRecords

public List<CdcRecord> parseRecords()

Description copied from interface: EventParser

Parse records from event.

Specified by:

parseRecords in interface EventParser<RichCdcRecord>

Returns:

empty if there is no records