org.apache.paimon.tag

Class TagTimeExtractor.WatermarkExtractor

java.lang.Object

org.apache.paimon.tag.TagTimeExtractor.WatermarkExtractor

All Implemented Interfaces:

TagTimeExtractor

Enclosing interface:

TagTimeExtractor

public static class TagTimeExtractor.WatermarkExtractor
extends Object
implements TagTimeExtractor

Extract time from snapshot watermark.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.paimon.tag.TagTimeExtractor

TagTimeExtractor.ProcessTimeExtractor, TagTimeExtractor.WatermarkExtractor

Method Summary

Modifier and Type	Method and Description
Optional<java.time.LocalDateTime>	extract(long timeMilli, Long watermark)

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.tag.TagTimeExtractor

create, createForAutoTag, createForTagPreview

Method Detail

extract

public Optional<java.time.LocalDateTime> extract(long timeMilli,
                                                 @Nullable
                                                 Long watermark)

Specified by:

extract in interface TagTimeExtractor