Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.scala | |
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 it is being processed and after
window evaluation was triggered by a
Trigger . |
Class and Description |
---|
Evictor
An
Evictor can remove elements from a pane before it is being processed and after
window evaluation was 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 it is being processed and after
window evaluation was triggered by a
Trigger . |
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 it is being processed and after
window evaluation was triggered by a
Trigger . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.