protected static class UpsertKafkaDynamicTableFactory.EncodingFormatWrapper extends Object implements EncodingFormat<SerializationSchema<RowData>>
Modifier and Type | Field and Description |
---|---|
static ChangelogMode |
SINK_CHANGELOG_MODE |
Constructor and Description |
---|
EncodingFormatWrapper(EncodingFormat<SerializationSchema<RowData>> innerEncodingFormat) |
Modifier and Type | Method and Description |
---|---|
SerializationSchema<RowData> |
createRuntimeEncoder(DynamicTableSink.Context context,
DataType consumedDataType)
Creates runtime encoder implementation that is configured to consume 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
applyWritableMetadata, listWritableMetadata
public static final ChangelogMode SINK_CHANGELOG_MODE
public EncodingFormatWrapper(EncodingFormat<SerializationSchema<RowData>> innerEncodingFormat)
public SerializationSchema<RowData> createRuntimeEncoder(DynamicTableSink.Context context, DataType consumedDataType)
EncodingFormat
createRuntimeEncoder
in interface EncodingFormat<SerializationSchema<RowData>>
public ChangelogMode getChangelogMode()
Format
getChangelogMode
in interface Format
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.