org.apache.flink.streaming.runtime.operators.windowing

Class WindowOperator.Timer<K,W extends Window>

java.lang.Object

org.apache.flink.streaming.runtime.operators.windowing.WindowOperator.Timer<K,W>

All Implemented Interfaces:

Comparable<WindowOperator.Timer<K,W>>

Enclosing class:

WindowOperator<K,IN,ACC,OUT,W extends Window>

protected static class WindowOperator.Timer<K,W extends Window>
extends Object
implements Comparable<WindowOperator.Timer<K,W>>

Internal class for keeping track of in-flight timers.

Field Summary

Fields

Modifier and Type	Field and Description
protected K	key
protected long	timestamp
protected W	window

Constructor Summary

Constructors

Constructor and Description
Timer(long timestamp, K key, W window)

Method Summary

Modifier and Type	Method and Description
int	compareTo(WindowOperator.Timer<K,W> o)
boolean	equals(Object o)
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

timestamp

protected long timestamp

key

protected K key

window

protected W extends Window window

Constructor Detail

Timer

public Timer(long timestamp,
             K key,
             W window)

Method Detail

compareTo

public int compareTo(WindowOperator.Timer<K,W> o)

Specified by:

compareTo in interface Comparable<WindowOperator.Timer<K,W extends Window>>

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