org.apache.paimon.tag

Interface TagTimeExtractor

All Known Implementing Classes:

TagTimeExtractor.ProcessTimeExtractor, TagTimeExtractor.WatermarkExtractor

public interface TagTimeExtractor

Extractor to extract tag time from Snapshot.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	TagTimeExtractor.ProcessTimeExtractor Extract time from snapshot time millis.
static class	TagTimeExtractor.WatermarkExtractor Extract time from snapshot watermark.

Method Summary

Modifier and Type	Method and Description
static TagTimeExtractor	create(CoreOptions.TagCreationMode mode, CoreOptions options)
static TagTimeExtractor	createForAutoTag(CoreOptions options)
static TagTimeExtractor	createForTagPreview(CoreOptions options)
Optional<java.time.LocalDateTime>	extract(long timeMilli, Long watermark)

Method Detail

extract

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

createForAutoTag

@Nullable
static TagTimeExtractor createForAutoTag(CoreOptions options)

createForTagPreview

@Nullable
static TagTimeExtractor createForTagPreview(CoreOptions options)

create

@Nullable
static TagTimeExtractor create(CoreOptions.TagCreationMode mode,
                                         CoreOptions options)