public class CanalJsonDecodingFormat extends Object implements DecodingFormat<DeserializationSchema<RowData>>
DecodingFormat
for Canal using JSON encoding.Constructor and Description |
---|
CanalJsonDecodingFormat(String database,
String table,
boolean ignoreParseErrors,
TimestampFormat timestampFormat) |
Modifier and Type | Method and Description |
---|---|
void |
applyReadableMetadata(List<String> metadataKeys)
Provides a list of metadata keys that the produced row must contain as appended metadata
columns.
|
DeserializationSchema<RowData> |
createRuntimeDecoder(DynamicTableSource.Context context,
DataType physicalDataType)
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.
|
Map<String,DataType> |
listReadableMetadata()
Returns the map of metadata keys and their corresponding data types that can be produced by
this format for reading.
|
public CanalJsonDecodingFormat(String database, String table, boolean ignoreParseErrors, TimestampFormat timestampFormat)
public DeserializationSchema<RowData> createRuntimeDecoder(DynamicTableSource.Context context, DataType physicalDataType)
DecodingFormat
createRuntimeDecoder
in interface DecodingFormat<DeserializationSchema<RowData>>
public Map<String,DataType> listReadableMetadata()
DecodingFormat
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()
.
listReadableMetadata
in interface DecodingFormat<DeserializationSchema<RowData>>
public void applyReadableMetadata(List<String> metadataKeys)
DecodingFormat
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)
.
applyReadableMetadata
in interface DecodingFormat<DeserializationSchema<RowData>>
public ChangelogMode getChangelogMode()
Format
getChangelogMode
in interface Format
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.