Uses of Class
org.apache.flink.streaming.api.windowing.triggers.AsyncProcessingTimeoutTrigger
-
Packages that use AsyncProcessingTimeoutTrigger Package Description org.apache.flink.streaming.api.windowing.triggers -
-
Uses of AsyncProcessingTimeoutTrigger in org.apache.flink.streaming.api.windowing.triggers
Methods in org.apache.flink.streaming.api.windowing.triggers that return AsyncProcessingTimeoutTrigger Modifier and Type Method Description static <T,W extends org.apache.flink.streaming.api.windowing.windows.Window>
AsyncProcessingTimeoutTrigger<T,W>AsyncProcessingTimeoutTrigger. of(org.apache.flink.runtime.asyncprocessing.operators.windowing.triggers.AsyncTrigger<T,W> nestedTrigger, Duration timeout)Creates a newAsyncProcessingTimeoutTriggerthat 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>
AsyncProcessingTimeoutTrigger<T,W>AsyncProcessingTimeoutTrigger. of(org.apache.flink.runtime.asyncprocessing.operators.windowing.triggers.AsyncTrigger<T,W> nestedTrigger, Duration timeout, boolean resetTimerOnNewRecord, boolean shouldClearOnTimeout)Creates a newAsyncProcessingTimeoutTriggerthat fires when the inner trigger is fired or when the timeout timer fires.
-