EncodingFormatFactory (Flink : 2.0-SNAPSHOT API)

Type Parameters:

I - runtime interface needed by the table sink

All Superinterfaces:

Factory, FormatFactory

All Known Subinterfaces:

BulkWriterFormatFactory, SerializationFormatFactory

All Known Implementing Classes:

AvroFileFormatFactory, AvroFormatFactory, CanalJsonFormatFactory, CsvFileFormatFactory, CsvFormatFactory, DebeziumAvroFormatFactory, DebeziumJsonFormatFactory, JsonFormatFactory, MaxwellJsonFormatFactory, OggJsonFormatFactory, OrcFileFormatFactory, ParquetFileFormatFactory, PbFileFormatFactory, PbFormatFactory, RawFormatFactory, RegistryAvroFormatFactory
```
@PublicEvolving
public interface EncodingFormatFactory<I>
extends FormatFactory
```
Base interface for configuring an EncodingFormat for a DynamicTableSink.
Depending on the kind of external system, a connector might support different encodings for reading and writing rows. This interface helps in making such formats pluggable.
The created Format instance is an intermediate representation that can be used to construct runtime implementation in a later step.

See Also:

FactoryUtil.createTableFactoryHelper(DynamicTableFactory, DynamicTableFactory.Context)

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`EncodingFormat<I>`	`createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)`	Creates a format from the given context and format options.

Methods inherited from interface org.apache.flink.table.factories.Factory
factoryIdentifier, optionalOptions, requiredOptions

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

- Method Detail
  - createEncodingFormat
```
EncodingFormat<I> createEncodingFormat(DynamicTableFactory.Context context,
                                       ReadableConfig formatOptions)
```
    Creates a format from the given context and format options.
    The format options have been projected to top-level options (e.g. from format.ignore-errors to ignore-errors).