org.apache.paimon.flink.action.cdc

Class CdcMetadataConverter.OpTsConverter

java.lang.Object

org.apache.paimon.flink.action.cdc.CdcMetadataConverter.OpTsConverter

All Implemented Interfaces:

Serializable, CdcMetadataConverter

Enclosing interface:

CdcMetadataConverter

public static class CdcMetadataConverter.OpTsConverter
extends Object
implements CdcMetadataConverter

It indicates the time that the change was made in the database. If the record is read from snapshot of the table instead of the binlog, the value is always 0.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.flink.action.cdc.CdcMetadataConverter

CdcMetadataConverter.DatabaseNameConverter, CdcMetadataConverter.OpTsConverter, CdcMetadataConverter.SchemaNameConverter, CdcMetadataConverter.TableNameConverter

Constructor Summary

Constructors

Constructor and Description
OpTsConverter()

Method Summary

Modifier and Type	Method and Description
String	columnName()
DataType	dataType()
String	read(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode source)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OpTsConverter

public OpTsConverter()

Method Detail

read

public String read(org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.JsonNode source)

Specified by:

read in interface CdcMetadataConverter

dataType

public DataType dataType()

Specified by:

dataType in interface CdcMetadataConverter

columnName

public String columnName()

Specified by:

columnName in interface CdcMetadataConverter