org.apache.flink.table.factories

Interface DeserializationSchemaFactory<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 DeserializationSchemaFactory<T>
extends TableFormatFactory<T>

Factory for creating configured instances of DeserializationSchema.

Method Summary

Modifier and Type	Method and Description
DeserializationSchema<T>	createDeserializationSchema(Map<String,String> properties) Creates and configures a DeserializationSchema 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

createDeserializationSchema

DeserializationSchema<T> createDeserializationSchema(Map<String,String> properties)

Creates and configures a DeserializationSchema 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