org.apache.flink.cdc.common.source

接口 SupportedMetadataColumn

所有超级接口:

Serializable

@Experimental
public interface SupportedMetadataColumn
extends Serializable

A metadata column that the source supports to read from the meta field.

方法概要

限定符和类型	方法和说明
Class<?>	getJavaClass() The returned java class of the reader.
String	getName() Column name.
DataType	getType() The data type of this column in Flink CDC.
Object	read(Map<String,String> metadata) Read the metadata from the DataChangeEvent.meta().

方法详细资料

getName

String getName()

Column name.

getType

DataType getType()

The data type of this column in Flink CDC.

getJavaClass

Class<?> getJavaClass()

The returned java class of the reader.

read

Object read(Map<String,String> metadata)

Read the metadata from the DataChangeEvent.meta().

参数:

metadata - the metadata returned from DataChangeEvent.meta()

返回:

the value of this metadata found by metadata name