InternalTimer (Flink : Streaming Java 1.18.1-cp7 API)

Type Parameters:

K - Type of the keys to which timers are scoped.

N - Type of the namespace to which timers are scoped.

All Superinterfaces:

org.apache.flink.runtime.state.Keyed<K>, org.apache.flink.runtime.state.PriorityComparable<InternalTimer<?,?>>

All Known Implementing Classes:

TimerHeapInternalTimer
```
@Internal
public interface InternalTimer<K,N>
extends org.apache.flink.runtime.state.PriorityComparable<InternalTimer<?,?>>, org.apache.flink.runtime.state.Keyed<K>
```
Internal interface for in-flight timers.

Field Summary

Fields
Modifier and Type	Field	Description
`static org.apache.flink.runtime.state.KeyExtractorFunction<InternalTimer<?,?>>`	`KEY_EXTRACTOR_FUNCTION`	Function to extract the key from a `InternalTimer`.
`static org.apache.flink.runtime.state.PriorityComparator<InternalTimer<?,?>>`	`TIMER_COMPARATOR`	Function to compare instances of `InternalTimer`.

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 org.apache.flink.runtime.state.KeyExtractorFunction<InternalTimer<?,?>> KEY_EXTRACTOR_FUNCTION
```
    Function to extract the key from a InternalTimer.
  - TIMER_COMPARATOR
```
static final org.apache.flink.runtime.state.PriorityComparator<InternalTimer<?,?>> TIMER_COMPARATOR
```
    Function to compare instances of InternalTimer.
- 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.
    
    Specified by:
    
    getKey in interface org.apache.flink.runtime.state.Keyed<K>
  - getNamespace
```
@Nonnull
N getNamespace()
```
    Returns the namespace that is bound to this timer.