I
- runtime interface needed by the table source@PublicEvolving public interface DecodingFormat<I> extends Format
Format
for a DynamicTableSource
for reading rows.Modifier and Type | Method and Description |
---|---|
default void |
applyReadableMetadata(List<String> metadataKeys)
Provides a list of metadata keys that the produced row must contain as appended metadata
columns.
|
I |
createRuntimeDecoder(DynamicTableSource.Context context,
DataType physicalDataType)
Creates runtime decoder implementation that is configured to produce data of the given data
type.
|
default Map<String,DataType> |
listReadableMetadata()
Returns the map of metadata keys and their corresponding data types that can be produced by
this format for reading.
|
getChangelogMode
I createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType)
default Map<String,DataType> listReadableMetadata()
Metadata columns add additional columns to the table's schema. A decoding format is responsible to add requested metadata columns at the end of produced rows.
See SupportsReadingMetadata
for more information.
Note: This method is only used if the outer DynamicTableSource
implements SupportsReadingMetadata
and calls this method in SupportsReadingMetadata.listReadableMetadata()
.
default void applyReadableMetadata(List<String> metadataKeys)
See SupportsReadingMetadata
for more information.
Note: This method is only used if the outer DynamicTableSource
implements SupportsReadingMetadata
and calls this method in SupportsReadingMetadata.applyReadableMetadata(List, DataType)
.
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.