Package | Description |
---|---|
org.apache.flink.state.api |
Modifier and Type | Method and Description |
---|---|
WindowedStateTransformation<T,K,W> |
WindowedStateTransformation.evictor(Evictor<? super T,? super W> evictor)
Sets the
Evictor that should be used to evict elements from a window before emission. |
WindowedStateTransformation<T,K,W> |
WindowedStateTransformation.trigger(Trigger<? super T,? super W> trigger)
Sets the
Trigger that should be used to trigger window emission. |
<W extends Window> |
KeyedStateTransformation.window(WindowAssigner<? super T,W> assigner)
Windows this transformation into a
WindowedOperatorTransformation , which bootstraps
state that can be restored by a WindowOperator . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.