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

Class DebeziumJsonDataFormat

java.lang.Object

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

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

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

All Implemented Interfaces:

DataFormat

public class DebeziumJsonDataFormat
extends AbstractJsonDataFormat

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

Constructor Summary

Constructors

Constructor and Description
DebeziumJsonDataFormat()

Method Summary

Modifier and Type	Method and Description
protected RecordParserFactory	parser() Factory for creating AbstractRecordParser.

Methods inherited from class org.apache.paimon.flink.action.cdc.format.AbstractJsonDataFormat

kafkaDeserializer, pulsarDeserializer

Methods inherited from class org.apache.paimon.flink.action.cdc.format.AbstractDataFormat

createKafkaDeserializer, createParser, createPulsarDeserializer

Methods inherited from class java.lang.Object

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

Constructor Detail

DebeziumJsonDataFormat

public DebeziumJsonDataFormat()

Method Detail

parser

protected RecordParserFactory parser()

Description copied from class: AbstractDataFormat

Factory for creating AbstractRecordParser.

Specified by:

parser in class AbstractDataFormat