org.apache.paimon.flink.sink.cdc

Class RichCdcMultiplexRecordEventParser

java.lang.Object

org.apache.paimon.flink.sink.cdc.RichCdcMultiplexRecordEventParser

All Implemented Interfaces:

EventParser<RichCdcMultiplexRecord>

public class RichCdcMultiplexRecordEventParser
extends Object
implements EventParser<RichCdcMultiplexRecord>

EventParser for RichCdcMultiplexRecord.

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
RichCdcMultiplexRecordEventParser(boolean caseSensitive)
RichCdcMultiplexRecordEventParser(NewTableSchemaBuilder schemaBuilder, Pattern includingPattern, Pattern excludingPattern, TableNameConverter tableNameConverter, Set<String> createdTables)

Method Summary

Modifier and Type	Method and Description
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.
String	parseTableName() Parse the table name from raw event.
void	setRawEvent(RichCdcMultiplexRecord record) 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

Constructor Detail

RichCdcMultiplexRecordEventParser

public RichCdcMultiplexRecordEventParser(boolean caseSensitive)

RichCdcMultiplexRecordEventParser

public RichCdcMultiplexRecordEventParser(@Nullable
                                         NewTableSchemaBuilder schemaBuilder,
                                         @Nullable
                                         Pattern includingPattern,
                                         @Nullable
                                         Pattern excludingPattern,
                                         TableNameConverter tableNameConverter,
                                         Set<String> createdTables)

Method Detail

setRawEvent

public void setRawEvent(RichCdcMultiplexRecord record)

Description copied from interface: EventParser

Set current raw event to the parser.

Specified by:

setRawEvent in interface EventParser<RichCdcMultiplexRecord>

parseTableName

public String parseTableName()

Description copied from interface: EventParser

Parse the table name from raw event.

Specified by:

parseTableName in interface EventParser<RichCdcMultiplexRecord>

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

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

Returns:

empty if there is no records

parseNewTable

public Optional<Schema> parseNewTable()

Description copied from interface: EventParser

Parse newly added table schema from event.

Specified by:

parseNewTable in interface EventParser<RichCdcMultiplexRecord>

Returns:

empty if there is no newly added table