org.apache.paimon.tag

Class TagPeriodHandler.BaseTagPeriodHandler

java.lang.Object

org.apache.paimon.tag.TagPeriodHandler.BaseTagPeriodHandler

All Implemented Interfaces:

TagPeriodHandler

Direct Known Subclasses:

TagPeriodHandler.DailyTagPeriodHandler, TagPeriodHandler.HourlyTagPeriodHandler, TagPeriodHandler.TwoHoursTagPeriodHandler

Enclosing interface:

TagPeriodHandler

public abstract static class TagPeriodHandler.BaseTagPeriodHandler
extends Object
implements TagPeriodHandler

Base implementation of TagPeriodHandler.

Nested Class Summary

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

TagPeriodHandler.BaseTagPeriodHandler, TagPeriodHandler.DailyTagPeriodHandler, TagPeriodHandler.HourlyTagPeriodHandler, TagPeriodHandler.TwoHoursTagPeriodHandler

Field Summary

Fields inherited from interface org.apache.paimon.tag.TagPeriodHandler

DAY_FORMATTER, DAY_FORMATTER_WITHOUT_DASHES, HOUR_FORMATTER, HOUR_FORMATTER_WITHOUT_DASHES

Constructor Summary

Constructors

Constructor and Description
BaseTagPeriodHandler()

Method Summary

Modifier and Type	Method and Description
protected abstract java.time.format.DateTimeFormatter	formatter()
boolean	isAutoTag(String tagName)
java.time.LocalDateTime	nextTagTime(java.time.LocalDateTime time)
java.time.LocalDateTime	normalizeToPreviousTag(java.time.LocalDateTime time)
protected abstract java.time.Duration	onePeriod()
java.time.LocalDateTime	tagToTime(String tag)
String	timeToTag(java.time.LocalDateTime time)
void	validateDelay(java.time.Duration delay)

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.TagPeriodHandler

create

Constructor Detail

BaseTagPeriodHandler

public BaseTagPeriodHandler()

Method Detail

onePeriod

protected abstract java.time.Duration onePeriod()

formatter

protected abstract java.time.format.DateTimeFormatter formatter()

validateDelay

public void validateDelay(java.time.Duration delay)

Specified by:

validateDelay in interface TagPeriodHandler

tagToTime

public java.time.LocalDateTime tagToTime(String tag)

Specified by:

tagToTime in interface TagPeriodHandler

normalizeToPreviousTag

public java.time.LocalDateTime normalizeToPreviousTag(java.time.LocalDateTime time)

Specified by:

normalizeToPreviousTag in interface TagPeriodHandler

timeToTag

public String timeToTag(java.time.LocalDateTime time)

Specified by:

timeToTag in interface TagPeriodHandler

nextTagTime

public java.time.LocalDateTime nextTagTime(java.time.LocalDateTime time)

Specified by:

nextTagTime in interface TagPeriodHandler

isAutoTag

public boolean isAutoTag(String tagName)

Specified by:

isAutoTag in interface TagPeriodHandler