Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.windowing.evictors | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations on data streams.
|
Class and Description |
---|
Evictor
An
Evictor can remove elements from a pane before/after the evaluation of WindowFunction
and after the window evaluation gets triggered by a Trigger |
Class and Description |
---|
Evictor
An
Evictor can remove elements from a pane before/after the evaluation of WindowFunction
and after the window evaluation gets triggered by a Trigger |
Class and Description |
---|
CountEvictor
An
Evictor that keeps up to a certain amount of elements. |
DeltaEvictor
An
Evictor that keeps elements based on a DeltaFunction and a threshold. |
Evictor
An
Evictor can remove elements from a pane before/after the evaluation of WindowFunction
and after the window evaluation gets triggered by a Trigger |
Evictor.EvictorContext
A context object that is given to
Evictor methods. |
TimeEvictor
An
Evictor that keeps elements for a certain amount of time. |
Class and Description |
---|
Evictor
An
Evictor can remove elements from a pane before/after the evaluation of WindowFunction
and after the window evaluation gets triggered by a Trigger |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.