Uses of Interface
org.apache.paimon.flink.sink.cdc.EventParser.Factory

Packages that use EventParser.Factory

Package	Description
org.apache.paimon.flink.action.cdc
org.apache.paimon.flink.sink.cdc

Uses of EventParser.Factory in org.apache.paimon.flink.action.cdc

Methods in org.apache.paimon.flink.action.cdc that return EventParser.Factory

Modifier and Type	Method and Description
protected EventParser.Factory<RichCdcMultiplexRecord>	SyncDatabaseActionBase.buildEventParserFactory()
protected EventParser.Factory<RichCdcMultiplexRecord>	SyncTableActionBase.buildEventParserFactory()
protected abstract EventParser.Factory<RichCdcMultiplexRecord>	SynchronizationActionBase.buildEventParserFactory()

Methods in org.apache.paimon.flink.action.cdc with parameters of type EventParser.Factory

Modifier and Type	Method and Description
protected void	SyncDatabaseActionBase.buildSink(org.apache.flink.streaming.api.datastream.DataStream<RichCdcMultiplexRecord> input, EventParser.Factory<RichCdcMultiplexRecord> parserFactory)
protected void	SyncTableActionBase.buildSink(org.apache.flink.streaming.api.datastream.DataStream<RichCdcMultiplexRecord> input, EventParser.Factory<RichCdcMultiplexRecord> parserFactory)
protected abstract void	SynchronizationActionBase.buildSink(org.apache.flink.streaming.api.datastream.DataStream<RichCdcMultiplexRecord> input, EventParser.Factory<RichCdcMultiplexRecord> parserFactory)

Uses of EventParser.Factory in org.apache.paimon.flink.sink.cdc

Methods in org.apache.paimon.flink.sink.cdc with parameters of type EventParser.Factory

Modifier and Type	Method and Description
FlinkCdcSyncDatabaseSinkBuilder<T>	FlinkCdcSyncDatabaseSinkBuilder.withParserFactory(EventParser.Factory<T> parserFactory)
CdcSinkBuilder<T>	CdcSinkBuilder.withParserFactory(EventParser.Factory<T> parserFactory)

Constructors in org.apache.paimon.flink.sink.cdc with parameters of type EventParser.Factory

Constructor and Description
CdcDynamicTableParsingProcessFunction(String database, Catalog.Loader catalogLoader, EventParser.Factory<T> parserFactory)
CdcMultiTableParsingProcessFunction(EventParser.Factory<T> parserFactory)
CdcParsingProcessFunction(EventParser.Factory<T> parserFactory)