org.apache.paimon.flink.action.cdc.mongodb

Class MongoDBCdcTimestampExtractor

java.lang.Object

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

org.apache.paimon.flink.action.cdc.mongodb.MongoDBCdcTimestampExtractor

All Implemented Interfaces:

Serializable, CdcTimestampExtractor

public class MongoDBCdcTimestampExtractor
extends CdcDebeziumTimestampExtractor

Timestamp extractor for MongoDB sources in CDC applications.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.paimon.flink.action.cdc.watermark.CdcDebeziumTimestampExtractor

objectMapper

Constructor Summary

Constructors

Constructor and Description
MongoDBCdcTimestampExtractor()

Method Summary

Modifier and Type	Method and Description
long	extractTimestamp(CdcSourceRecord record)

Methods inherited from class java.lang.Object

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

Constructor Detail

MongoDBCdcTimestampExtractor

public MongoDBCdcTimestampExtractor()

Method Detail

extractTimestamp

public long extractTimestamp(CdcSourceRecord record)
                      throws org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException

Throws:

org.apache.paimon.shade.jackson2.com.fasterxml.jackson.core.JsonProcessingException