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

Class MaxwellDataFormat

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.maxwell.MaxwellDataFormat

All Implemented Interfaces:

DataFormat

public class MaxwellDataFormat
extends AbstractJsonDataFormat

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

Constructor Summary

Constructors

Constructor and Description
MaxwellDataFormat()

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

MaxwellDataFormat

public MaxwellDataFormat()

Method Detail

parser

protected RecordParserFactory parser()

Description copied from class: AbstractDataFormat

Factory for creating AbstractRecordParser.

Specified by:

parser in class AbstractDataFormat