public abstract class AbstractDataFormat extends Object implements DataFormat
DataFormat
.Constructor and Description |
---|
AbstractDataFormat() |
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) |
protected abstract java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord>> |
kafkaDeserializer()
Deserializer for Kafka Record.
|
protected abstract RecordParserFactory |
parser()
Factory for creating AbstractRecordParser.
|
protected abstract java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord>> |
pulsarDeserializer()
Deserializer for Pulsar Record.
|
protected abstract RecordParserFactory parser()
protected abstract java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord>> kafkaDeserializer()
protected abstract java.util.function.Function<org.apache.flink.configuration.Configuration,org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord>> pulsarDeserializer()
public AbstractRecordParser createParser(TypeMapping typeMapping, List<ComputedColumn> computedColumns)
DataFormat
AbstractRecordParser
for this data format with the
specified configurations.createParser
in interface DataFormat
computedColumns
- List of computed columns to be considered by the parser.AbstractRecordParser
.public org.apache.flink.streaming.connectors.kafka.KafkaDeserializationSchema<CdcSourceRecord> createKafkaDeserializer(org.apache.flink.configuration.Configuration cdcSourceConfig)
createKafkaDeserializer
in interface DataFormat
public org.apache.flink.api.common.serialization.DeserializationSchema<CdcSourceRecord> createPulsarDeserializer(org.apache.flink.configuration.Configuration cdcSourceConfig)
createPulsarDeserializer
in interface DataFormat
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.