org.apache.flink.state.api.runtime

Class VoidTriggerable<K,N>

java.lang.Object

org.apache.flink.state.api.runtime.VoidTriggerable<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:

Triggerable<K,N>

@Internal
public final class VoidTriggerable<K,N>
extends Object
implements Triggerable<K,N>

A Triggerable that does nothing.

Method Summary

Modifier and Type	Method and Description
static <K,N> VoidTriggerable<K,N>	instance()
void	onEventTime(InternalTimer<K,N> timer) Invoked when an event-time timer fires.
void	onProcessingTime(InternalTimer<K,N> timer) Invoked when a processing-time timer fires.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

instance

public static <K,N> VoidTriggerable<K,N> instance()

onEventTime

public void onEventTime(InternalTimer<K,N> timer)

Description copied from interface: Triggerable

Invoked when an event-time timer fires.

Specified by:

onEventTime in interface Triggerable<K,N>

onProcessingTime

public void onProcessingTime(InternalTimer<K,N> timer)

Description copied from interface: Triggerable

Invoked when a processing-time timer fires.

Specified by:

onProcessingTime in interface Triggerable<K,N>