org.apache.flink.table.factories

Interface DeserializationFormatFactory

All Superinterfaces:

DecodingFormatFactory<DeserializationSchema<RowData>>, Factory, FormatFactory

All Known Implementing Classes:

AvroFormatFactory, CanalJsonFormatFactory, ChangelogCsvFormatFactory, CsvFormatFactory, DebeziumAvroFormatFactory, DebeziumJsonFormatFactory, JsonFormatFactory, MaxwellJsonFormatFactory, OggJsonFormatFactory, PbFormatFactory, RawFormatFactory, RegistryAvroFormatFactory

@PublicEvolving
public interface DeserializationFormatFactory
extends DecodingFormatFactory<DeserializationSchema<RowData>>

Factory for creating a DecodingFormat for DeserializationSchema.

See Also:

FactoryUtil.createTableFactoryHelper(DynamicTableFactory, DynamicTableFactory.Context)

Method Summary

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

createDecodingFormat

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

forwardOptions

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

factoryIdentifier, optionalOptions, requiredOptions