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

Interface CdcTimestampExtractor

All Superinterfaces:

Serializable

All Known Implementing Classes:

CdcDebeziumTimestampExtractor, MessageQueueCdcTimestampExtractor, MongoDBCdcTimestampExtractor, MysqlCdcTimestampExtractor

public interface CdcTimestampExtractor
extends Serializable

Interface defining the contract for CDC timestamp extraction.

Method Summary

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

Method Detail

extractTimestamp

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