Package org.apache.flink.streaming.api.operators

Class TimerHeapInternalTimer<K,N>

java.lang.Object

org.apache.flink.streaming.api.operators.TimerHeapInternalTimer<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 Implemented Interfaces:

HeapPriorityQueueElement, Keyed<K>, PriorityComparable<InternalTimer<?,?>>, InternalTimer<K,N>

@Internal
public final class TimerHeapInternalTimer<K,N>
extends Object
implements InternalTimer<K,N>, HeapPriorityQueueElement

Implementation of InternalTimer to use with a HeapPriorityQueueSet.

Field Summary

Fields inherited from interface org.apache.flink.runtime.state.heap.HeapPriorityQueueElement

NOT_CONTAINED

Fields inherited from interface org.apache.flink.streaming.api.operators.InternalTimer

KEY_EXTRACTOR_FUNCTION, TIMER_COMPARATOR

Constructor Summary

Constructors

Constructor	Description
TimerHeapInternalTimer(long timestamp, K key, N namespace)

Method Summary

Modifier and Type	Method	Description
int	comparePriorityTo(InternalTimer<?,?> other)
boolean	equals(Object o)
int	getInternalIndex()	Returns the current index of this object in the internal array of HeapPriorityQueue.
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.
int	hashCode()
void	setInternalIndex(int newIndex)	Sets the current index of this object in the HeapPriorityQueue and should only be called by the owning HeapPriorityQueue.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TimerHeapInternalTimer

public TimerHeapInternalTimer(long timestamp,
                              @Nonnull
                              K key,
                              @Nonnull
                              N namespace)

Method Detail

getTimestamp

public long getTimestamp()

Description copied from interface: InternalTimer

Returns the timestamp of the timer. This value determines the point in time when the timer will fire.

Specified by:

getTimestamp in interface InternalTimer<K,N>

getKey

@Nonnull
public K getKey()

Description copied from interface: InternalTimer

Returns the key that is bound to this timer.

Specified by:

getKey in interface InternalTimer<K,N>

Specified by:

getKey in interface Keyed<K>

getNamespace

@Nonnull
public N getNamespace()

Description copied from interface: InternalTimer

Returns the namespace that is bound to this timer.

Specified by:

getNamespace in interface InternalTimer<K,N>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

getInternalIndex

public int getInternalIndex()

Description copied from interface: HeapPriorityQueueElement

Returns the current index of this object in the internal array of HeapPriorityQueue.

Specified by:

getInternalIndex in interface HeapPriorityQueueElement

setInternalIndex

public void setInternalIndex(int newIndex)

Description copied from interface: HeapPriorityQueueElement

Sets the current index of this object in the HeapPriorityQueue and should only be called by the owning HeapPriorityQueue.

Specified by:

setInternalIndex in interface HeapPriorityQueueElement

Parameters:

newIndex - the new index in the timer heap.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

comparePriorityTo

public int comparePriorityTo(@Nonnull
                             InternalTimer<?,?> other)

Specified by:

comparePriorityTo in interface PriorityComparable<K>