Package | Description |
---|---|
org.apache.flink.streaming.api.windowing.triggers |
Modifier and Type | Method and Description |
---|---|
static <T,W extends Window> |
ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger,
java.time.Duration timeout)
Creates a new
ProcessingTimeoutTrigger that fires when the inner trigger is fired or
when the timeout timer fires. |
static <T,W extends Window> |
ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger,
java.time.Duration timeout,
boolean resetTimerOnNewRecord,
boolean shouldClearOnTimeout)
Creates a new
ProcessingTimeoutTrigger that fires when the inner trigger is fired or
when the timeout timer fires. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.