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

Packages that use SerializationSchema

Package	Description
org.apache.flink.api.common.serialization
org.apache.flink.connector.base.table
org.apache.flink.connector.file.table
org.apache.flink.connector.firehose.sink
org.apache.flink.connector.firehose.table
org.apache.flink.connector.kafka.sink
org.apache.flink.connector.kinesis.sink
org.apache.flink.connector.kinesis.table
org.apache.flink.connector.pulsar.sink.writer.serializer
org.apache.flink.formats.avro
org.apache.flink.formats.avro.glue.schema.registry
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.glue.schema.registry
org.apache.flink.formats.json.maxwell
org.apache.flink.formats.json.ogg
org.apache.flink.formats.raw
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.sink
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.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.factories

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

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

Modifier and Type	Class and Description
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 SerializationSchema in org.apache.flink.connector.base.table

Methods in org.apache.flink.connector.base.table that return types with arguments of type SerializationSchema

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	AsyncDynamicTableSinkFactory.AsyncDynamicSinkContext.getEncodingFormat()

Uses of SerializationSchema in org.apache.flink.connector.file.table

Constructors in org.apache.flink.connector.file.table with parameters of type SerializationSchema

Constructor and Description
SerializationSchemaAdapter(SerializationSchema<RowData> serializationSchema)

Uses of SerializationSchema in org.apache.flink.connector.firehose.sink

Methods in org.apache.flink.connector.firehose.sink with parameters of type SerializationSchema

Modifier and Type	Method and Description
KinesisFirehoseSinkBuilder<InputT>	KinesisFirehoseSinkBuilder.setSerializationSchema(SerializationSchema<InputT> serializationSchema) Allows the user to specify a serialization schema to serialize each record to persist to Firehose.
KinesisFirehoseSinkElementConverter.Builder<InputT>	KinesisFirehoseSinkElementConverter.Builder.setSerializationSchema(SerializationSchema<InputT> serializationSchema)

Uses of SerializationSchema in org.apache.flink.connector.firehose.table

Method parameters in org.apache.flink.connector.firehose.table with type arguments of type SerializationSchema

Modifier and Type	Method and Description
KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder	KinesisFirehoseDynamicSink.KinesisFirehoseDynamicSinkBuilder.setEncodingFormat(EncodingFormat<SerializationSchema<RowData>> encodingFormat)

Constructor parameters in org.apache.flink.connector.firehose.table with type arguments of type SerializationSchema

Constructor and Description
KinesisFirehoseDynamicSink(Integer maxBatchSize, Integer maxInFlightRequests, Integer maxBufferedRequests, Long maxBufferSizeInBytes, Long maxTimeInBufferMS, Boolean failOnError, DataType consumedDataType, String deliveryStream, Properties firehoseClientProperties, EncodingFormat<SerializationSchema<RowData>> encodingFormat)

Uses of SerializationSchema in org.apache.flink.connector.kafka.sink

Methods in org.apache.flink.connector.kafka.sink with parameters of type SerializationSchema

Modifier and Type	Method and Description
<T extends IN> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setKeySerializationSchema(SerializationSchema<? super T> keySerializationSchema) Sets a SerializationSchema which is used to serialize the incoming element to the key of the ProducerRecord.
<T extends IN> KafkaRecordSerializationSchemaBuilder<T>	KafkaRecordSerializationSchemaBuilder.setValueSerializationSchema(SerializationSchema<T> valueSerializationSchema) Sets a SerializationSchema which is used to serialize the incoming element to the value of the ProducerRecord.

Uses of SerializationSchema in org.apache.flink.connector.kinesis.sink

Methods in org.apache.flink.connector.kinesis.sink with parameters of type SerializationSchema

Modifier and Type	Method and Description
KinesisStreamsSinkBuilder<InputT>	KinesisStreamsSinkBuilder.setSerializationSchema(SerializationSchema<InputT> serializationSchema)
KinesisStreamsSinkElementConverter.Builder<InputT>	KinesisStreamsSinkElementConverter.Builder.setSerializationSchema(SerializationSchema<InputT> serializationSchema)

Uses of SerializationSchema in org.apache.flink.connector.kinesis.table

Method parameters in org.apache.flink.connector.kinesis.table with type arguments of type SerializationSchema

Modifier and Type	Method and Description
KinesisDynamicSink.KinesisDynamicTableSinkBuilder	KinesisDynamicSink.KinesisDynamicTableSinkBuilder.setEncodingFormat(EncodingFormat<SerializationSchema<RowData>> encodingFormat)

Constructor parameters in org.apache.flink.connector.kinesis.table with type arguments of type SerializationSchema

Constructor and Description
KinesisDynamicSink(Integer maxBatchSize, Integer maxInFlightRequests, Integer maxBufferedRequests, Long maxBufferSizeInBytes, Long maxTimeInBufferMS, Boolean failOnError, DataType consumedDataType, String stream, Properties kinesisClientProperties, EncodingFormat<SerializationSchema<RowData>> encodingFormat, PartitionKeyGenerator<RowData> partitioner)

Uses of SerializationSchema in org.apache.flink.connector.pulsar.sink.writer.serializer

Methods in org.apache.flink.connector.pulsar.sink.writer.serializer with parameters of type SerializationSchema

Modifier and Type	Method and Description
static <T> PulsarSerializationSchema<T>	PulsarSerializationSchema.flinkSchema(SerializationSchema<T> serializationSchema) Create a PulsarSerializationSchema by using the flink's SerializationSchema.

Constructors in org.apache.flink.connector.pulsar.sink.writer.serializer with parameters of type SerializationSchema

Constructor and Description
PulsarSerializationSchemaWrapper(SerializationSchema<IN> serializationSchema)

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

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

Modifier and Type	Class and Description
class	AvroRowDataSerializationSchema Serialization schema that serializes RowData into Avro bytes.
class	AvroRowSerializationSchema Deprecated. The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own SerializationSchema.
class	AvroSerializationSchema<T> Serialization schema that serializes to Avro binary format.
class	RegistryAvroSerializationSchema<T> Serialization schema that serializes to Avro binary format.

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	AvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

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

Constructor and Description
AvroRowDataSerializationSchema(RowType rowType, SerializationSchema<org.apache.avro.generic.GenericRecord> nestedSchema, RowDataToAvroConverters.RowDataToAvroConverter runtimeConverter) Creates an Avro serialization schema with the given record row type, nested schema and runtime converters.

Uses of SerializationSchema in org.apache.flink.formats.avro.glue.schema.registry

Classes in org.apache.flink.formats.avro.glue.schema.registry that implement SerializationSchema

Modifier and Type	Class and Description
class	GlueSchemaRegistryAvroSerializationSchema<T> AWS Glue Schema Registry Serialization schema to serialize to Avro binary format for Flink Producer user.

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

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

Modifier and Type	Class and Description
class	ConfluentRegistryAvroSerializationSchema<T> Serialization schema that serializes to Avro binary format that uses Confluent Schema Registry.

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	RegistryAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

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

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

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

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	DebeziumAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

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

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

Modifier and Type	Class and Description
class	CsvRowDataSerializationSchema Serialization schema that serializes an object of Flink Table & SQL internal data structure into a CSV bytes.
class	CsvRowSerializationSchema Deprecated. The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own SerializationSchema.

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	CsvFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

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

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

Modifier and Type	Class and Description
class	JsonRowDataSerializationSchema Serialization schema that serializes an object of Flink internal data structure into a JSON bytes.
class	JsonRowSerializationSchema Deprecated. The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own SerializationSchema.

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	JsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

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

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

Modifier and Type	Class and Description
class	CanalJsonSerializationSchema Serialization schema that serializes an object of Flink Table/SQL internal data structure RowData into a Canal JSON bytes.

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	CanalJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

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

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

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

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	DebeziumJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of SerializationSchema in org.apache.flink.formats.json.glue.schema.registry

Classes in org.apache.flink.formats.json.glue.schema.registry that implement SerializationSchema

Modifier and Type	Class and Description
class	GlueSchemaRegistryJsonSerializationSchema<T> AWS Glue Schema Registry Serialization schema to serialize to JSON Schema binary format for Flink Producer user.

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

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

Modifier and Type	Class and Description
class	MaxwellJsonSerializationSchema Serialization schema from Flink Table/SQL internal data structure RowData to maxwell-Json.

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	MaxwellJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of SerializationSchema in org.apache.flink.formats.json.ogg

Classes in org.apache.flink.formats.json.ogg that implement SerializationSchema

Modifier and Type	Class and Description
class	OggJsonSerializationSchema Serialization schema from Flink Table/SQL internal data structure RowData to Ogg JSON.

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	OggJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of SerializationSchema in org.apache.flink.formats.raw

Classes in org.apache.flink.formats.raw that implement SerializationSchema

Modifier and Type	Class and Description
class	RawFormatSerializationSchema Serialization schema that serializes an RowData object into raw (byte based) value.

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

Modifier and Type	Method and Description
EncodingFormat<SerializationSchema<RowData>>	RawFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of SerializationSchema in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type SerializationSchema

Modifier and Type	Method and Description
DataStreamSink<T>	DataStream.writeToSocket(String hostName, int port, SerializationSchema<T> schema) Writes the DataStream to a socket as a byte array.

Uses of SerializationSchema in org.apache.flink.streaming.api.functions.sink

Constructors in org.apache.flink.streaming.api.functions.sink with parameters of type SerializationSchema

Constructor and Description
SocketClientSink(String hostName, int port, SerializationSchema<IN> schema) Creates a new SocketClientSink.
SocketClientSink(String hostName, int port, SerializationSchema<IN> schema, int maxNumRetries) Creates a new SocketClientSink that retries connections upon failure up to a given number of times.
SocketClientSink(String hostName, int port, SerializationSchema<IN> schema, int maxNumRetries, boolean autoflush) Creates a new SocketClientSink that retries connections upon failure up to a given number of times.

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

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

Modifier and Type	Method and Description
<IN> PubSubSink.ProjectNameBuilder<IN>	PubSubSink.SerializationSchemaBuilder.withSerializationSchema(SerializationSchema<IN> deserializationSchema) Set the SerializationSchema used to Serialize objects to be added as payloads of PubSubMessages.

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

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

Constructor and Description
FlinkKafkaProducer(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig) Deprecated. Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<IN> customPartitioner, FlinkKafkaProducer.Semantic semantic, int kafkaProducersPoolSize) Deprecated. Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig, Optional<FlinkKafkaPartitioner<IN>> customPartitioner) Deprecated. Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer(String brokerList, String topicId, SerializationSchema<IN> serializationSchema) Deprecated. Creates a FlinkKafkaProducer for a given topic.

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

Methods in org.apache.flink.streaming.connectors.kafka.internals that return SerializationSchema

Modifier and Type	Method and Description
SerializationSchema<T>	KeyedSerializationSchemaWrapper.getSerializationSchema()

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

Constructor and Description
KafkaSerializationSchemaWrapper(String topic, FlinkKafkaPartitioner<T> partitioner, boolean writeTimestamp, SerializationSchema<T> serializationSchema)
KeyedSerializationSchemaWrapper(SerializationSchema<T> serializationSchema)

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

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

Modifier and Type	Field and Description
protected EncodingFormat<SerializationSchema<RowData>>	KafkaDynamicSink.keyEncodingFormat Optional format for encoding keys to Kafka.
protected EncodingFormat<SerializationSchema<RowData>>	KafkaDynamicSink.valueEncodingFormat Format for encoding values to Kafka.

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

Modifier and Type	Method and Description
SerializationSchema<RowData>	UpsertKafkaDynamicTableFactory.EncodingFormatWrapper.createRuntimeEncoder(DynamicTableSink.Context context, DataType consumedDataType)

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

Modifier and Type	Method and Description
protected KafkaDynamicSink	KafkaDynamicTableFactory.createKafkaTableSink(DataType physicalDataType, EncodingFormat<SerializationSchema<RowData>> keyEncodingFormat, EncodingFormat<SerializationSchema<RowData>> valueEncodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, String topic, Properties properties, FlinkKafkaPartitioner<RowData> partitioner, DeliveryGuarantee deliveryGuarantee, Integer parallelism, String transactionalIdPrefix)
protected KafkaDynamicSink	KafkaDynamicTableFactory.createKafkaTableSink(DataType physicalDataType, EncodingFormat<SerializationSchema<RowData>> keyEncodingFormat, EncodingFormat<SerializationSchema<RowData>> valueEncodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, String topic, Properties properties, FlinkKafkaPartitioner<RowData> partitioner, DeliveryGuarantee deliveryGuarantee, Integer parallelism, String transactionalIdPrefix)

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

Constructor and Description
EncodingFormatWrapper(EncodingFormat<SerializationSchema<RowData>> innerEncodingFormat)
KafkaDynamicSink(DataType consumedDataType, DataType physicalDataType, EncodingFormat<SerializationSchema<RowData>> keyEncodingFormat, EncodingFormat<SerializationSchema<RowData>> valueEncodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, String topic, Properties properties, FlinkKafkaPartitioner<RowData> partitioner, DeliveryGuarantee deliveryGuarantee, boolean upsertMode, SinkBufferFlushMode flushMode, Integer parallelism, String transactionalIdPrefix)
KafkaDynamicSink(DataType consumedDataType, DataType physicalDataType, EncodingFormat<SerializationSchema<RowData>> keyEncodingFormat, EncodingFormat<SerializationSchema<RowData>> valueEncodingFormat, int[] keyProjection, int[] valueProjection, String keyPrefix, String topic, Properties properties, FlinkKafkaPartitioner<RowData> partitioner, DeliveryGuarantee deliveryGuarantee, boolean upsertMode, SinkBufferFlushMode flushMode, Integer parallelism, String transactionalIdPrefix)

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

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

Constructor and Description
FlinkKinesisProducer(SerializationSchema<OUT> schema, Properties configProps) Deprecated. Create a new FlinkKinesisProducer.

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

Fields in org.apache.flink.streaming.connectors.rabbitmq declared as SerializationSchema

Modifier and Type	Field and Description
protected SerializationSchema<IN>	RMQSink.schema

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

Constructor and Description
RMQSink(RMQConnectionConfig rmqConnectionConfig, SerializationSchema<IN> schema, RMQSinkPublishOptions<IN> publishOptions)
RMQSink(RMQConnectionConfig rmqConnectionConfig, SerializationSchema<IN> schema, RMQSinkPublishOptions<IN> publishOptions, SerializableReturnListener returnListener)
RMQSink(RMQConnectionConfig rmqConnectionConfig, String queueName, SerializationSchema<IN> schema)

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

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

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

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

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

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

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

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

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

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

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

Modifier and Type	Method and Description
SerializationSchema<T>	SerializationSchemaFactory.createSerializationSchema(Map<String,String> properties) Deprecated. Creates and configures a [[SerializationSchema]] using the given properties.