Package org.apache.flink.table.runtime.functions

Class Timer

java.lang.Object

org.apache.flink.table.runtime.functions.Timer

All Implemented Interfaces:

Comparable<Timer>

@PublicEvolving
public class Timer
extends Object
implements Comparable<Timer>

A timer registered by a ProcessTableFunction during testing.

Method Summary

Modifier and Type	Method	Description
int	compareTo(Timer other)	Comparison of timers is done by timestamp first, then by name (unnamed timers sort after named ones), then by partition key, for a deterministic firing order.
boolean	equals(Object o)
Row	getKey()
String	getName()
long	getTimestamp()
<T> T	getTimestampAs(Class<T> timeClass)
boolean	hasFired()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

getTimestamp

public long getTimestamp()

getTimestampAs

public <T> T getTimestampAs(Class<T> timeClass)

getName

@Nullable
public String getName()

getKey

public Row getKey()

hasFired

public boolean hasFired()

compareTo

public int compareTo(Timer other)

Comparison of timers is done by timestamp first, then by name (unnamed timers sort after named ones), then by partition key, for a deterministic firing order.

Specified by:

compareTo in interface Comparable<Timer>

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