Uses of Class
org.apache.flink.streaming.api.windowing.triggers.ProcessingTimeoutTrigger
-
Packages that use ProcessingTimeoutTrigger Package Description org.apache.flink.streaming.api.windowing.triggers -
-
Uses of ProcessingTimeoutTrigger in org.apache.flink.streaming.api.windowing.triggers
Methods in org.apache.flink.streaming.api.windowing.triggers that return ProcessingTimeoutTrigger Modifier and Type Method Description static <T,W extends org.apache.flink.streaming.api.windowing.windows.Window>
ProcessingTimeoutTrigger<T,W>ProcessingTimeoutTrigger. of(org.apache.flink.streaming.api.windowing.triggers.Trigger<T,W> nestedTrigger, Duration timeout)Creates a newProcessingTimeoutTriggerthat fires when the inner trigger is fired or when the timeout timer fires.static <T,W extends org.apache.flink.streaming.api.windowing.windows.Window>
ProcessingTimeoutTrigger<T,W>ProcessingTimeoutTrigger. of(org.apache.flink.streaming.api.windowing.triggers.Trigger<T,W> nestedTrigger, Duration timeout, boolean resetTimerOnNewRecord, boolean shouldClearOnTimeout)Creates a newProcessingTimeoutTriggerthat fires when the inner trigger is fired or when the timeout timer fires.
-