Interface InternalTimer<K,N>
-
- Type Parameters:
K
- Type of the keys to which timers are scoped.N
- Type of the namespace to which timers are scoped.
- All Superinterfaces:
Keyed<K>
,PriorityComparable<InternalTimer<?,?>>
- All Known Implementing Classes:
TimerHeapInternalTimer
@Internal public interface InternalTimer<K,N> extends PriorityComparable<InternalTimer<?,?>>, Keyed<K>
Internal interface for in-flight timers.
-
-
Field Summary
Fields Modifier and Type Field Description static KeyExtractorFunction<InternalTimer<?,?>>
KEY_EXTRACTOR_FUNCTION
Function to extract the key from aInternalTimer
.static PriorityComparator<InternalTimer<?,?>>
TIMER_COMPARATOR
Function to compare instances ofInternalTimer
.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description K
getKey()
Returns the key that is bound to this timer.N
getNamespace()
Returns the namespace that is bound to this timer.long
getTimestamp()
Returns the timestamp of the timer.-
Methods inherited from interface org.apache.flink.runtime.state.PriorityComparable
comparePriorityTo
-
-
-
-
Field Detail
-
KEY_EXTRACTOR_FUNCTION
static final KeyExtractorFunction<InternalTimer<?,?>> KEY_EXTRACTOR_FUNCTION
Function to extract the key from aInternalTimer
.
-
TIMER_COMPARATOR
static final PriorityComparator<InternalTimer<?,?>> TIMER_COMPARATOR
Function to compare instances ofInternalTimer
.
-
-
Method Detail
-
getTimestamp
long getTimestamp()
Returns the timestamp of the timer. This value determines the point in time when the timer will fire.
-
getKey
@Nonnull K getKey()
Returns the key that is bound to this timer.
-
getNamespace
@Nonnull N getNamespace()
Returns the namespace that is bound to this timer.
-
-