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

Class AbstractJsonDataFormat

java.lang.Object

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

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

All Implemented Interfaces:

DataFormat

Direct Known Subclasses:

CanalDataFormat, DebeziumJsonDataFormat, JsonDataFormat, MaxwellDataFormat, OggDataFormat

public abstract class AbstractJsonDataFormat
extends AbstractDataFormat

The message queue's record json deserialization class common implementation of DataFormat.

Constructor Summary

Constructors

Constructor and Description
AbstractJsonDataFormat()

Method Summary

Modifier and Type	Method and Description
protected java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord>>	kafkaDeserializer() Deserializer for Kafka Record.
protected java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord>>	pulsarDeserializer() Deserializer for Pulsar Record.

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

createKafkaDeserializer, createParser, createPulsarDeserializer, parser

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractJsonDataFormat

public AbstractJsonDataFormat()

Method Detail

kafkaDeserializer

protected java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord>> kafkaDeserializer()

Description copied from class: AbstractDataFormat

Deserializer for Kafka Record.

Specified by:

kafkaDeserializer in class AbstractDataFormat

pulsarDeserializer

protected java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord>> pulsarDeserializer()

Description copied from class: AbstractDataFormat

Deserializer for Pulsar Record.

Specified by:

pulsarDeserializer in class AbstractDataFormat