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