org.apache.flink.streaming.api.operators

Class InternalTimer<K,N>

java.lang.Object

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

Comparable<InternalTimer<K,N>>

@Internal
public class InternalTimer<K,N>
extends Object
implements Comparable<InternalTimer<K,N>>

Internal class for keeping track of in-flight timers.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InternalTimer.TimerSerializer<K,N> A TypeSerializer used to serialize/deserialize a InternalTimer.

Constructor Summary

Constructors

Constructor and Description
InternalTimer(long timestamp, K key, N namespace)

Method Summary

Modifier and Type	Method and Description
int	compareTo(InternalTimer<K,N> o)
boolean	equals(Object o)
K	getKey()
N	getNamespace()
long	getTimestamp()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalTimer

public InternalTimer(long timestamp,
                     K key,
                     N namespace)

Method Detail

getTimestamp

public long getTimestamp()

getKey

public K getKey()

getNamespace

public N getNamespace()

compareTo

public int compareTo(InternalTimer<K,N> o)

Specified by:

compareTo in interface Comparable<InternalTimer<K,N>>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object