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.testutils.formats
org.apache.flink.connector.upserttest.sink
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.formats.json.ogg
org.apache.flink.formats.protobuf
org.apache.flink.formats.protobuf.serialize
org.apache.flink.formats.raw
org.apache.flink.python.util
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.functions.sink.legacy
org.apache.flink.streaming.examples.statemachine.kafka

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	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	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	Description
SerializationSchemaAdapter(SerializationSchema<RowData> serializationSchema)

Uses of SerializationSchema in org.apache.flink.connector.testutils.formats

Methods in org.apache.flink.connector.testutils.formats with parameters of type SerializationSchema

Modifier and Type	Method	Description
static void	SchemaTestUtils.open(SerializationSchema<?> schema)	Opens the given schema with a mock initialization context.

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

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

Modifier and Type	Method	Description
UpsertTestSinkBuilder<IN>	UpsertTestSinkBuilder.setKeySerializationSchema(SerializationSchema<IN> keySerializationSchema)	Sets the key SerializationSchema that transforms incoming records to byte[].
UpsertTestSinkBuilder<IN>	UpsertTestSinkBuilder.setValueSerializationSchema(SerializationSchema<IN> valueSerializationSchema)	Sets the value SerializationSchema that transforms incoming records to byte[].

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

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

Modifier and Type	Class	Description
class	AvroRowDataSerializationSchema	Serialization schema that serializes RowData into Avro bytes.
class	AvroRowSerializationSchema	Serialization schema that serializes Row into Avro bytes.
class	AvroSerializationSchema<T>	Serialization schema that serializes to Avro binary format.
class	RegistryAvroSerializationSchema<T>	Serialization schema that serializes to Avro format.

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

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

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

Constructor	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.registry.confluent

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

Modifier and Type	Class	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	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	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	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	Description
class	CsvRowDataSerializationSchema	Serialization schema that serializes an object of Flink Table & SQL internal data structure into a CSV bytes.
class	CsvRowSerializationSchema	Serialization schema that serializes an object of Flink types into a CSV bytes.

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

Modifier and Type	Method	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	Description
class	JsonRowDataSerializationSchema	Serialization schema that serializes an object of Flink internal data structure into a JSON bytes.
class	JsonRowSerializationSchema	Serialization schema that serializes an object of Flink types into a JSON bytes.
class	JsonSerializationSchema<T>	SerializationSchema that serializes an object to a JSON String.

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

Modifier and Type	Method	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	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	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	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	Description
EncodingFormat<SerializationSchema<RowData>>	DebeziumJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

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	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	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	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	Description
EncodingFormat<SerializationSchema<RowData>>	OggJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

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

Methods in org.apache.flink.formats.protobuf that return SerializationSchema

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

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

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

Uses of SerializationSchema in org.apache.flink.formats.protobuf.serialize

Classes in org.apache.flink.formats.protobuf.serialize that implement SerializationSchema

Modifier and Type	Class	Description
class	PbRowDataSerializationSchema	Serialization schema from Flink to Protobuf types.

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

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

Modifier and Type	Class	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	Description
EncodingFormat<SerializationSchema<RowData>>	RawFormatFactory.createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)

Uses of SerializationSchema in org.apache.flink.python.util

Classes in org.apache.flink.python.util that implement SerializationSchema

Modifier and Type	Class	Description
static class	PythonConnectorUtils.SecondColumnSerializationSchema<T>	A SerializationSchema for Row that only serialize the second column using a wrapped SerializationSchema for PythonConnectorUtils.SecondColumnSerializationSchema.

Constructors in org.apache.flink.python.util with parameters of type SerializationSchema

Constructor	Description
SecondColumnSerializationSchema(SerializationSchema<T> wrappedSchema)	The constructor.

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	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.legacy

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

Constructor	Description
SocketClientSink(String hostName, int port, SerializationSchema<IN> schema)	Deprecated. Creates a new SocketClientSink.
SocketClientSink(String hostName, int port, SerializationSchema<IN> schema, int maxNumRetries)	Deprecated. 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)	Deprecated. Creates a new SocketClientSink that retries connections upon failure up to a given number of times.

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	Description
class	EventDeSerializationSchema	A serializer and deserializer for the Event type.