public final class ChangelogCsvFormat extends Object implements DecodingFormat<DeserializationSchema<RowData>>
ChangelogCsvFormat
is a decoding format that uses a DeserializationSchema
during runtime. It supports emitting INSERT
and DELETE
changes.Constructor and Description |
---|
ChangelogCsvFormat(String columnDelimiter) |
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.
|
ChangelogMode |
getChangelogMode()
Returns the set of changes that a connector (and transitively the planner) can expect during
runtime.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
applyReadableMetadata, listReadableMetadata
public ChangelogCsvFormat(String columnDelimiter)
public DeserializationSchema<RowData> createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType)
DecodingFormat
createRuntimeDecoder
in interface DecodingFormat<DeserializationSchema<RowData>>
context
- the context provides several utilities required to instantiate the runtime
decoder implementation of the formatproducedDataType
- For more details check the documentation of DecodingFormat
.public ChangelogMode getChangelogMode()
Format
getChangelogMode
in interface Format
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.