Class OpTsMetadataColumn
- java.lang.Object
-
- org.apache.flink.cdc.connectors.values.source.OpTsMetadataColumn
-
- All Implemented Interfaces:
Serializable,SupportedMetadataColumn
public class OpTsMetadataColumn extends Object implements SupportedMetadataColumn
ASupportedMetadataColumnfor op_ts.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description OpTsMetadataColumn()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Class<?>getJavaClass()The returned java class of the reader.StringgetName()Column name.DataTypegetType()The data type of this column in Flink CDC.Objectread(Map<String,String> metadata)Read the metadata from theDataChangeEvent.meta().
-
-
-
Method Detail
-
getName
public String getName()
Description copied from interface:SupportedMetadataColumnColumn name.- Specified by:
getNamein interfaceSupportedMetadataColumn
-
getType
public DataType getType()
Description copied from interface:SupportedMetadataColumnThe data type of this column in Flink CDC.- Specified by:
getTypein interfaceSupportedMetadataColumn
-
getJavaClass
public Class<?> getJavaClass()
Description copied from interface:SupportedMetadataColumnThe returned java class of the reader.- Specified by:
getJavaClassin interfaceSupportedMetadataColumn
-
read
public Object read(Map<String,String> metadata)
Description copied from interface:SupportedMetadataColumnRead the metadata from theDataChangeEvent.meta().- Specified by:
readin interfaceSupportedMetadataColumn- Parameters:
metadata- the metadata returned fromDataChangeEvent.meta()- Returns:
- the value of this metadata found by metadata name
-
-