org.apache.paimon.flink.action.cdc.watermark

Class CdcDebeziumTimestampExtractor

java.lang.Object

org.apache.paimon.flink.action.cdc.watermark.CdcDebeziumTimestampExtractor

All Implemented Interfaces:

Serializable, CdcTimestampExtractor

Direct Known Subclasses:

MongoDBCdcTimestampExtractor, MysqlCdcTimestampExtractor

public abstract class CdcDebeziumTimestampExtractor
extends Object
implements CdcTimestampExtractor

Timestamp extractor for Cdc debezium deserialization.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.ObjectMapper	objectMapper

Constructor Summary

Constructors

Constructor and Description
CdcDebeziumTimestampExtractor()

Method Summary

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.flink.action.cdc.watermark.CdcTimestampExtractor

extractTimestamp

Field Detail

objectMapper

protected final org.apache.paimon.shade.jackson2.com.fasterxml.jackson.databind.ObjectMapper objectMapper

Constructor Detail

CdcDebeziumTimestampExtractor

public CdcDebeziumTimestampExtractor()