I
- runtime interface needed by the table source@PublicEvolving public interface DecodingFormatFactory<I> extends Factory
DecodingFormat
for ScanTableSource
and LookupTableSource
.
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 |
---|---|
DecodingFormat<I> |
createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
factoryIdentifier, optionalOptions, requiredOptions
DecodingFormat<I> createDecodingFormat(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.