org.apache.paimon.flink.action.cdc.format

Interface DataFormat

All Known Implementing Classes:

AbstractDataFormat, AbstractJsonDataFormat, CanalDataFormat, DebeziumAvroDataFormat, DebeziumJsonDataFormat, JsonDataFormat, MaxwellDataFormat, OggDataFormat

public interface DataFormat

Supports the message queue's data format and provides definitions for the message queue's record deserialization class and parsing class AbstractRecordParser.

Method Summary

Modifier and Type	Method and Description
org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord>	createKafkaDeserializer(org.apache.flink.configuration.Configuration cdcSourceConfig)
AbstractRecordParser	createParser(TypeMapping typeMapping, List<ComputedColumn> computedColumns) Creates a new instance of AbstractRecordParser for this data format with the specified configurations.
org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord>	createPulsarDeserializer(org.apache.flink.configuration.Configuration cdcSourceConfig)

Method Detail

createParser

AbstractRecordParser createParser(TypeMapping typeMapping,
                                  List<ComputedColumn> computedColumns)

Creates a new instance of AbstractRecordParser for this data format with the specified configurations.

Parameters:

computedColumns - List of computed columns to be considered by the parser.

Returns:

A new instance of AbstractRecordParser.

createKafkaDeserializer

org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord> createKafkaDeserializer(org.apache.flink.configuration.Configuration cdcSourceConfig)

createPulsarDeserializer

org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord> createPulsarDeserializer(org.apache.flink.configuration.Configuration cdcSourceConfig)