I
- runtime interface needed by the table sink@PublicEvolving public interface EncodingFormatFactory<I> extends Factory
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.
Modifier and Type | Method and Description |
---|---|
EncodingFormat<I> |
createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
factoryIdentifier, optionalOptions, requiredOptions
EncodingFormat<I> createEncodingFormat(DynamicTableFactory.Context context, ReadableConfig formatOptions)
The format options have been projected to top-level options (e.g. from format.ignore-errors
to ignore-errors
).
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.