org.apache.paimon.tag

Class TagTimeExtractor.ProcessTimeExtractor

java.lang.Object

org.apache.paimon.tag.TagTimeExtractor.ProcessTimeExtractor

All Implemented Interfaces:

TagTimeExtractor

Enclosing interface:

TagTimeExtractor

public static class TagTimeExtractor.ProcessTimeExtractor
extends Object
implements TagTimeExtractor

Extract time from snapshot time millis.

Nested Class Summary

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

TagTimeExtractor.ProcessTimeExtractor, TagTimeExtractor.WatermarkExtractor

Constructor Summary

Constructors

Constructor and Description
ProcessTimeExtractor()

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

Constructor Detail

ProcessTimeExtractor

public ProcessTimeExtractor()

Method Detail

extract

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

Specified by:

extract in interface TagTimeExtractor