org.apache.flink.table.factories

Interface SerializationSchemaFactory<T>

Type Parameters:

T - record type that the format produces or consumes.

All Superinterfaces:

TableFactory, TableFormatFactory<T>

All Known Implementing Classes:

AvroRowFormatFactory, CsvRowFormatFactory, JsonRowFormatFactory

@PublicEvolving
public interface SerializationSchemaFactory<T>
extends TableFormatFactory<T>

Factory for creating configured instances of SerializationSchema.

Method Summary

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

Methods inherited from interface org.apache.flink.table.factories.TableFormatFactory

supportedProperties, supportsSchemaDerivation

Methods inherited from interface org.apache.flink.table.factories.TableFactory

requiredContext

Method Detail

createSerializationSchema

SerializationSchema<T> createSerializationSchema(Map<String,String> properties)

Creates and configures a [[SerializationSchema]] using the given properties.

Parameters:

properties - normalized properties describing the format

Returns:

the configured serialization schema or null if the factory cannot provide an instance of this class