org.apache.flink.streaming.api.operators

Interface Triggerable<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 Known Implementing Classes:

AbstractPythonStreamGroupAggregateOperator, AbstractStreamArrowPythonBoundedRangeOperator, AbstractStreamArrowPythonBoundedRowsOperator, AbstractStreamArrowPythonOverWindowAggregateFunctionOperator, AggregateWindowOperator, BaseTwoInputStreamOperatorWithStateRetention, BatchCoBroadcastWithKeyedOperator, BatchGroupedReduceOperator, CepOperator, CoBroadcastWithKeyedOperator, EmbeddedPythonBatchKeyedCoBroadcastProcessOperator, EmbeddedPythonKeyedCoProcessOperator, EmbeddedPythonKeyedProcessOperator, EmbeddedPythonWindowOperator, EvictingWindowOperator, ExternalPythonBatchKeyedCoBroadcastProcessOperator, ExternalPythonKeyedCoProcessOperator, ExternalPythonKeyedProcessOperator, IntervalJoinOperator, KeyedCoProcessOperator, KeyedCoProcessOperatorWithWatermarkDelay, KeyedProcessOperator, KeyedProcessOperator, KeyedTwoInputBroadcastProcessOperator, KeyedTwoInputNonBroadcastProcessOperator, KeyedTwoOutputProcessOperator, LegacyKeyedCoProcessOperator, LegacyKeyedProcessOperator, ProcTimeSortOperator, PythonStreamGroupAggregateOperator, PythonStreamGroupTableAggregateOperator, PythonStreamGroupWindowAggregateOperator, RowTimeSortOperator, StreamArrowPythonGroupWindowAggregateFunctionOperator, StreamArrowPythonProcTimeBoundedRangeOperator, StreamArrowPythonProcTimeBoundedRowsOperator, StreamArrowPythonRowTimeBoundedRangeOperator, StreamArrowPythonRowTimeBoundedRowsOperator, TableAggregateWindowOperator, TemporalProcessTimeJoinOperator, TemporalRowTimeJoinOperator, UnalignedWindowTableFunctionOperator, VoidTriggerable, WindowAggOperator, WindowJoinOperator, WindowOperator, WindowOperator

@Internal
public interface Triggerable<K,N>

Interface for things that can be called by InternalTimerService.

Method Summary

Modifier and Type	Method and Description
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.

Method Detail

onEventTime

void onEventTime(InternalTimer<K,N> timer)
          throws Exception

Invoked when an event-time timer fires.

Throws:

Exception

onProcessingTime

void onProcessingTime(InternalTimer<K,N> timer)
               throws Exception

Invoked when a processing-time timer fires.

Throws:

Exception