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

Class MessageQueueCdcTimestampExtractor

java.lang.Object

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

All Implemented Interfaces:

Serializable, CdcTimestampExtractor

public class MessageQueueCdcTimestampExtractor
extends Object
implements CdcTimestampExtractor

Timestamp extractor for Kafka/Pulsar sources in CDC applications.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MessageQueueCdcTimestampExtractor()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageQueueCdcTimestampExtractor

public MessageQueueCdcTimestampExtractor()

Method Detail

extractTimestamp

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

Specified by:

extractTimestamp in interface CdcTimestampExtractor

Throws:

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