Uses of Interface
org.apache.flink.api.common.serialization.DeserializationSchema

Packages that use DeserializationSchema

Package	Description
org.apache.flink.api.common.serialization
org.apache.flink.formats.avro
org.apache.flink.formats.avro.registry.confluent
org.apache.flink.formats.avro.registry.confluent.debezium
org.apache.flink.formats.csv
org.apache.flink.formats.json
org.apache.flink.formats.json.canal
org.apache.flink.formats.json.debezium
org.apache.flink.formats.json.maxwell
org.apache.flink.streaming.connectors.gcp.pubsub
org.apache.flink.streaming.connectors.kafka
org.apache.flink.streaming.connectors.kafka.internals
org.apache.flink.streaming.connectors.kafka.table
org.apache.flink.streaming.connectors.kinesis
org.apache.flink.streaming.connectors.kinesis.serialization
org.apache.flink.streaming.connectors.kinesis.table
org.apache.flink.streaming.connectors.rabbitmq
org.apache.flink.streaming.examples.statemachine.kafka
org.apache.flink.streaming.kafka.test.base
org.apache.flink.streaming.util.serialization
org.apache.flink.table.examples.java.connectors
org.apache.flink.table.factories
org.apache.flink.table.filesystem
org.apache.flink.table.formats.raw

Uses of DeserializationSchema in org.apache.flink.api.common.serialization

Classes in org.apache.flink.api.common.serialization that implement DeserializationSchema

Modifier and Type	Class and Description
class	AbstractDeserializationSchema<T> The deserialization schema describes how to turn the byte messages delivered by certain data sources (for example Apache Kafka) into data types (Java/Scala objects) that are processed by Flink.
class	SimpleStringSchema Very simple serialization schema for strings.
class	TypeInformationSerializationSchema<T> A serialization and deserialization schema that uses Flink's serialization stack to transform typed from and to byte arrays.

Uses of DeserializationSchema in org.apache.flink.formats.avro

Classes in org.apache.flink.formats.avro that implement DeserializationSchema

Modifier and Type	Class and Description
class	AvroDeserializationSchema<T> Deserialization schema that deserializes from Avro binary format.
class	AvroRowDataDeserializationSchema Deserialization schema from Avro bytes to RowData.
class	AvroRowDeserializationSchema Deserialization schema from Avro bytes to Row.
class	RegistryAvroDeserializationSchema<T> Deserialization schema that deserializes from Avro binary format using SchemaCoder.

Methods in org.apache.flink.formats.avro that return DeserializationSchema

Modifier and Type	Method and Description
DeserializationSchema<Row>	AvroRowFormatFactory.createDeserializationSchema(Map<String,String> properties)

Methods in org.apache.flink.formats.avro that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	AvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Constructors in org.apache.flink.formats.avro with parameters of type DeserializationSchema

Constructor and Description
AvroRowDataDeserializationSchema(DeserializationSchema<org.apache.avro.generic.GenericRecord> nestedSchema, AvroToRowDataConverters.AvroToRowDataConverter runtimeConverter, TypeInformation<RowData> typeInfo) Creates a Avro deserialization schema for the given logical type.

Uses of DeserializationSchema in org.apache.flink.formats.avro.registry.confluent

Classes in org.apache.flink.formats.avro.registry.confluent that implement DeserializationSchema

Modifier and Type	Class and Description
class	ConfluentRegistryAvroDeserializationSchema<T> Deserialization schema that deserializes from Avro binary format using SchemaCoder that uses Confluent Schema Registry.

Methods in org.apache.flink.formats.avro.registry.confluent that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	RegistryAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DeserializationSchema in org.apache.flink.formats.avro.registry.confluent.debezium

Classes in org.apache.flink.formats.avro.registry.confluent.debezium that implement DeserializationSchema

Modifier and Type	Class and Description
class	DebeziumAvroDeserializationSchema Deserialization schema from Debezium Avro to Flink Table/SQL internal data structure RowData.

Methods in org.apache.flink.formats.avro.registry.confluent.debezium that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	DebeziumAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DeserializationSchema in org.apache.flink.formats.csv

Classes in org.apache.flink.formats.csv that implement DeserializationSchema

Modifier and Type	Class and Description
class	CsvRowDataDeserializationSchema Deserialization schema from CSV to Flink Table & SQL internal data structures.
class	CsvRowDeserializationSchema Deserialization schema from CSV to Flink types.

Methods in org.apache.flink.formats.csv that return DeserializationSchema

Modifier and Type	Method and Description
DeserializationSchema<Row>	CsvRowFormatFactory.createDeserializationSchema(Map<String,String> properties)

Methods in org.apache.flink.formats.csv that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	CsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DeserializationSchema in org.apache.flink.formats.json

Classes in org.apache.flink.formats.json that implement DeserializationSchema

Modifier and Type	Class and Description
class	JsonNodeDeserializationSchema DeserializationSchema that deserializes a JSON String into an ObjectNode.
class	JsonRowDataDeserializationSchema Deserialization schema from JSON to Flink Table/SQL internal data structure RowData.
class	JsonRowDeserializationSchema Deserialization schema from JSON to Flink types.

Methods in org.apache.flink.formats.json that return DeserializationSchema

Modifier and Type	Method and Description
DeserializationSchema<Row>	JsonRowFormatFactory.createDeserializationSchema(Map<String,String> properties)

Methods in org.apache.flink.formats.json that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	JsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DeserializationSchema in org.apache.flink.formats.json.canal

Classes in org.apache.flink.formats.json.canal that implement DeserializationSchema

Modifier and Type	Class and Description
class	CanalJsonDeserializationSchema Deserialization schema from Canal JSON to Flink Table/SQL internal data structure RowData.

Methods in org.apache.flink.formats.json.canal that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	CanalJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DeserializationSchema in org.apache.flink.formats.json.debezium

Classes in org.apache.flink.formats.json.debezium that implement DeserializationSchema

Modifier and Type	Class and Description
class	DebeziumJsonDeserializationSchema Deserialization schema from Debezium JSON to Flink Table/SQL internal data structure RowData.

Methods in org.apache.flink.formats.json.debezium that return DeserializationSchema

Modifier and Type	Method and Description
DeserializationSchema<RowData>	DebeziumJsonDecodingFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType)

Methods in org.apache.flink.formats.json.debezium that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	DebeziumJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DeserializationSchema in org.apache.flink.formats.json.maxwell

Classes in org.apache.flink.formats.json.maxwell that implement DeserializationSchema

Modifier and Type	Class and Description
class	MaxwellJsonDeserializationSchema Deserialization schema from Maxwell JSON to Flink Table/SQL internal data structure RowData.

Methods in org.apache.flink.formats.json.maxwell that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	MaxwellJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of DeserializationSchema in org.apache.flink.streaming.connectors.gcp.pubsub

Methods in org.apache.flink.streaming.connectors.gcp.pubsub with parameters of type DeserializationSchema

Modifier and Type	Method and Description
<OUT> PubSubSource.ProjectNameBuilder<OUT>	PubSubSource.DeserializationSchemaBuilder.withDeserializationSchema(DeserializationSchema<OUT> deserializationSchema) Set the DeserializationSchema used to deserialize incoming PubSubMessages.

Uses of DeserializationSchema in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka that return DeserializationSchema

Modifier and Type	Method and Description
DeserializationSchema<Row>	KafkaTableSourceBase.getDeserializationSchema() Deprecated. Returns the deserialization schema.

Methods in org.apache.flink.streaming.connectors.kafka with parameters of type DeserializationSchema

Modifier and Type	Method and Description
protected abstract FlinkKafkaConsumerBase<Row>	KafkaTableSourceBase.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Deprecated. Creates a version-specific Kafka consumer.
protected FlinkKafkaConsumerBase<Row>	KafkaTableSource.createKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Deprecated.
protected abstract KafkaTableSourceBase	KafkaTableSourceSinkFactoryBase.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Deprecated. Constructs the version-specific Kafka table source.
protected KafkaTableSourceBase	KafkaTableSourceSinkFactory.createKafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Map<String,String> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Deprecated.
protected FlinkKafkaConsumerBase<Row>	KafkaTableSourceBase.getKafkaConsumer(String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Deprecated. Returns a version-specific Kafka consumer with the start position configured.

Constructors in org.apache.flink.streaming.connectors.kafka with parameters of type DeserializationSchema

Constructor and Description
FlinkKafkaConsumer(List<String> topics, DeserializationSchema<T> deserializer, Properties props) Creates a new Kafka streaming source consumer.
FlinkKafkaConsumer(Pattern subscriptionPattern, DeserializationSchema<T> valueDeserializer, Properties props) Creates a new Kafka streaming source consumer.
FlinkKafkaConsumer(String topic, DeserializationSchema<T> valueDeserializer, Properties props) Creates a new Kafka streaming source consumer.
KafkaTableSource(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Deprecated. Creates a generic Kafka StreamTableSource.
KafkaTableSource(TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Deprecated. Creates a generic Kafka StreamTableSource.
KafkaTableSourceBase(TableSchema schema, Optional<String> proctimeAttribute, List<RowtimeAttributeDescriptor> rowtimeAttributeDescriptors, Optional<Map<String,String>> fieldMapping, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis) Deprecated. Creates a generic Kafka StreamTableSource.
KafkaTableSourceBase(TableSchema schema, String topic, Properties properties, DeserializationSchema<Row> deserializationSchema) Deprecated. Creates a generic Kafka StreamTableSource.

Uses of DeserializationSchema in org.apache.flink.streaming.connectors.kafka.internals

Constructors in org.apache.flink.streaming.connectors.kafka.internals with parameters of type DeserializationSchema

Constructor and Description
KafkaDeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema)

Uses of DeserializationSchema in org.apache.flink.streaming.connectors.kafka.table

Fields in org.apache.flink.streaming.connectors.kafka.table with type parameters of type DeserializationSchema

Modifier and Type	Field and Description
protected DecodingFormat<DeserializationSchema<RowData>>	KafkaDynamicSource.keyDecodingFormat Optional format for decoding keys from Kafka.
protected DecodingFormat<DeserializationSchema<RowData>>	KafkaDynamicSource.valueDecodingFormat Format for decoding values from Kafka.

Methods in org.apache.flink.streaming.connectors.kafka.table that return DeserializationSchema

Modifier and Type	Method and Description
DeserializationSchema<RowData>	UpsertKafkaDynamicTableFactory.DecodingFormatWrapper.createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType)

Methods in org.apache.flink.streaming.connectors.kafka.table with parameters of type DeserializationSchema

Modifier and Type	Method and Description
protected FlinkKafkaConsumer<RowData>	KafkaDynamicSource.createKafkaConsumer(DeserializationSchema<RowData> keyDeserialization, DeserializationSchema<RowData> valueDeserialization, TypeInformation<RowData> producedTypeInfo)
protected FlinkKafkaConsumer<RowData>	KafkaDynamicSource.createKafkaConsumer(DeserializationSchema<RowData> keyDeserialization, DeserializationSchema<RowData> valueDeserialization, TypeInformation<RowData> producedTypeInfo)

Method parameters in org.apache.flink.streaming.connectors.kafka.table with type arguments of type DeserializationSchema

Modifier and Type	Method and Description
protected KafkaDynamicSource	KafkaDynamicTableFactory.createKafkaTableSource(DataType physicalDataType, DecodingFormat<DeserializationSchema<RowData>> keyDecodingFormat, DecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, List<String> topics, Pattern topicPattern, Properties properties, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)
protected KafkaDynamicSource	KafkaDynamicTableFactory.createKafkaTableSource(DataType physicalDataType, DecodingFormat<DeserializationSchema<RowData>> keyDecodingFormat, DecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, List<String> topics, Pattern topicPattern, Properties properties, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis)

Constructor parameters in org.apache.flink.streaming.connectors.kafka.table with type arguments of type DeserializationSchema

Constructor and Description
DecodingFormatWrapper(DecodingFormat<DeserializationSchema<RowData>> innerDecodingFormat)
KafkaDynamicSource(DataType physicalDataType, DecodingFormat<DeserializationSchema<RowData>> keyDecodingFormat, DecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, List<String> topics, Pattern topicPattern, Properties properties, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis, boolean upsertMode)
KafkaDynamicSource(DataType physicalDataType, DecodingFormat<DeserializationSchema<RowData>> keyDecodingFormat, DecodingFormat<DeserializationSchema<RowData>> valueDecodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, List<String> topics, Pattern topicPattern, Properties properties, StartupMode startupMode, Map<KafkaTopicPartition,Long> specificStartupOffsets, long startupTimestampMillis, boolean upsertMode)

Uses of DeserializationSchema in org.apache.flink.streaming.connectors.kinesis

Constructors in org.apache.flink.streaming.connectors.kinesis with parameters of type DeserializationSchema

Constructor and Description
FlinkDynamoDBStreamsConsumer(String stream, DeserializationSchema<T> deserializer, Properties config) Constructor of FlinkDynamoDBStreamsConsumer.
FlinkKinesisConsumer(String stream, DeserializationSchema<T> deserializer, Properties configProps) Creates a new Flink Kinesis Consumer.

Uses of DeserializationSchema in org.apache.flink.streaming.connectors.kinesis.serialization

Constructors in org.apache.flink.streaming.connectors.kinesis.serialization with parameters of type DeserializationSchema

Constructor and Description
KinesisDeserializationSchemaWrapper(DeserializationSchema<T> deserializationSchema)

Uses of DeserializationSchema in org.apache.flink.streaming.connectors.kinesis.table

Constructors in org.apache.flink.streaming.connectors.kinesis.table with parameters of type DeserializationSchema

Constructor and Description
RowDataKinesisDeserializationSchema(DeserializationSchema<RowData> physicalDeserializer, TypeInformation<RowData> producedTypeInfo, List<RowDataKinesisDeserializationSchema.Metadata> requestedMetadataFields)

Constructor parameters in org.apache.flink.streaming.connectors.kinesis.table with type arguments of type DeserializationSchema

Constructor and Description
KinesisDynamicSource(DataType physicalDataType, String stream, Properties consumerProperties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat)
KinesisDynamicSource(DataType physicalDataType, String stream, Properties consumerProperties, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, DataType producedDataType, List<RowDataKinesisDeserializationSchema.Metadata> requestedMetadataFields)

Uses of DeserializationSchema in org.apache.flink.streaming.connectors.rabbitmq

Constructors in org.apache.flink.streaming.connectors.rabbitmq with parameters of type DeserializationSchema

Constructor and Description
RMQSource(RMQConnectionConfig rmqConnectionConfig, String queueName, boolean usesCorrelationId, DeserializationSchema<OUT> deserializationSchema) Creates a new RabbitMQ source.
RMQSource(RMQConnectionConfig rmqConnectionConfig, String queueName, DeserializationSchema<OUT> deserializationSchema) Creates a new RabbitMQ source with at-least-once message processing guarantee when checkpointing is enabled.

Uses of DeserializationSchema in org.apache.flink.streaming.examples.statemachine.kafka

Classes in org.apache.flink.streaming.examples.statemachine.kafka that implement DeserializationSchema

Modifier and Type	Class and Description
class	EventDeSerializer A serializer and deserializer for the Event type.

Uses of DeserializationSchema in org.apache.flink.streaming.kafka.test.base

Classes in org.apache.flink.streaming.kafka.test.base that implement DeserializationSchema

Modifier and Type	Class and Description
class	KafkaEventSchema The serialization schema for the KafkaEvent type.

Uses of DeserializationSchema in org.apache.flink.streaming.util.serialization

Subinterfaces of DeserializationSchema in org.apache.flink.streaming.util.serialization

Modifier and Type	Interface and Description
interface	DeserializationSchema<T> Deprecated. Use DeserializationSchema instead.

Uses of DeserializationSchema in org.apache.flink.table.examples.java.connectors

Classes in org.apache.flink.table.examples.java.connectors that implement DeserializationSchema

Modifier and Type	Class and Description
class	ChangelogCsvDeserializer The ChangelogCsvDeserializer contains a simple parsing logic for converting bytes into Row of Integer and String with a RowKind.

Methods in org.apache.flink.table.examples.java.connectors that return DeserializationSchema

Modifier and Type	Method and Description
DeserializationSchema<RowData>	ChangelogCsvFormat.createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType)

Methods in org.apache.flink.table.examples.java.connectors that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	ChangelogCsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Constructors in org.apache.flink.table.examples.java.connectors with parameters of type DeserializationSchema

Constructor and Description
SocketSourceFunction(String hostname, int port, byte byteDelimiter, DeserializationSchema<RowData> deserializer)

Constructor parameters in org.apache.flink.table.examples.java.connectors with type arguments of type DeserializationSchema

Constructor and Description
SocketDynamicTableSource(String hostname, int port, byte byteDelimiter, DecodingFormat<DeserializationSchema<RowData>> decodingFormat, DataType producedDataType)

Uses of DeserializationSchema in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories that return DeserializationSchema

Modifier and Type	Method and Description
DeserializationSchema<T>	DeserializationSchemaFactory.createDeserializationSchema(Map<String,String> properties) Creates and configures a DeserializationSchema using the given properties.

Uses of DeserializationSchema in org.apache.flink.table.filesystem

Constructors in org.apache.flink.table.filesystem with parameters of type DeserializationSchema

Constructor and Description
DeserializationSchemaAdapter(DeserializationSchema<RowData> deserializationSchema, TableSchema schema, int[] projectFields, List<String> partitionKeys, String defaultPartValue)

Constructor parameters in org.apache.flink.table.filesystem with type arguments of type DeserializationSchema

Constructor and Description
FileSystemTableSource(DynamicTableFactory.Context context, DecodingFormat<BulkFormat<RowData,FileSourceSplit>> bulkReaderFormat, DecodingFormat<DeserializationSchema<RowData>> deserializationFormat, FileSystemFormatFactory formatFactory)

Uses of DeserializationSchema in org.apache.flink.table.formats.raw

Classes in org.apache.flink.table.formats.raw that implement DeserializationSchema

Modifier and Type	Class and Description
class	RawFormatDeserializationSchema Deserialization schema from raw (byte based) value to Flink Table/SQL internal data structure RowData.

Methods in org.apache.flink.table.formats.raw that return types with arguments of type DeserializationSchema

Modifier and Type	Method and Description
DecodingFormat<DeserializationSchema<RowData>>	RawFormatFactory.createDecodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)