protected static class UpsertKafkaDynamicTableFactory.DecodingFormatWrapper extends Object implements DecodingFormat<DeserializationSchema<RowData>>
Constructor and Description |
---|
DecodingFormatWrapper(DecodingFormat<DeserializationSchema<RowData>> innerDecodingFormat) |
Modifier and Type | Method and Description |
---|---|
DeserializationSchema<RowData> |
createRuntimeDecoder(DynamicTableSource.Context context,
DataType producedDataType)
Creates runtime decoder implementation that is configured to produce data of the given data
type.
|
boolean |
equals(Object obj) |
ChangelogMode |
getChangelogMode()
Returns the set of changes that a connector (and transitively the planner) can expect during
runtime.
|
int |
hashCode() |
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait
applyReadableMetadata, listReadableMetadata
public DecodingFormatWrapper(DecodingFormat<DeserializationSchema<RowData>> innerDecodingFormat)
public DeserializationSchema<RowData> createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType)
DecodingFormat
createRuntimeDecoder
in interface DecodingFormat<DeserializationSchema<RowData>>
public ChangelogMode getChangelogMode()
Format
getChangelogMode
in interface Format
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.