org.apache.paimon.flink.sink.cdc

Interface EventParser<T>

Type Parameters:

T - CDC change event type

All Known Implementing Classes:

RichCdcMultiplexRecordEventParser, RichEventParser

@Experimental
public interface EventParser<T>

Parse a CDC change event to a list of DataFields or CdcRecord.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	EventParser.Factory<T> Factory to create an EventParser.

Method Summary

Modifier and Type	Method and Description
default Optional<Schema>	parseNewTable() Parse newly added table schema from event.
List<CdcRecord>	parseRecords() Parse records from event.
List<DataField>	parseSchemaChange() Parse new schema if this event contains schema change.
default String	parseTableName() Parse the table name from raw event.
void	setRawEvent(T rawEvent) Set current raw event to the parser.

Method Detail

setRawEvent

void setRawEvent(T rawEvent)

Set current raw event to the parser.

parseTableName

default String parseTableName()

Parse the table name from raw event.

parseSchemaChange

List<DataField> parseSchemaChange()

Parse new schema if this event contains schema change.

Returns:

empty if there is no schema change

parseRecords

List<CdcRecord> parseRecords()

Parse records from event.

Returns:

empty if there is no records

parseNewTable

default Optional<Schema> parseNewTable()

Parse newly added table schema from event.

Returns:

empty if there is no newly added table