public abstract class AbstractJsonDataFormat extends AbstractDataFormat
DataFormat
.Constructor and Description |
---|
AbstractJsonDataFormat() |
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.
|
createKafkaDeserializer, createParser, createPulsarDeserializer, parser
protected java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord>> kafkaDeserializer()
AbstractDataFormat
kafkaDeserializer
in class AbstractDataFormat
protected java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord>> pulsarDeserializer()
AbstractDataFormat
pulsarDeserializer
in class AbstractDataFormat
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.