SupportedMetadataColumn (flink-cdc-parent 3.8-SNAPSHOT API)

All Superinterfaces:

Serializable

All Known Implementing Classes:

DatabaseNameMetadataColumn, OpTsMetadataColumn, OpTsMetadataColumn, OpTsMetadataColumn, SchemaNameMetadataColumn, TableNameMetadataColumn, TimestampTypeMetadataColumn
```
@Experimental
public interface SupportedMetadataColumn
extends Serializable
```
A metadata column that the source supports to read from the meta field.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`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()`.

- Method Detail
  - 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().
    
    Parameters:
    
    metadata - the metadata returned from DataChangeEvent.meta()
    
    Returns:
    
    the value of this metadata found by metadata name