Class TopSpeedWindowing
- java.lang.Object
-
- org.apache.flink.streaming.examples.windowing.TopSpeedWindowing
-
public class TopSpeedWindowing extends Object
An example of grouped stream windowing where different eviction and trigger policies can be used. A source fetches events from cars containing their id, their current speed (kmh), overall elapsed distance (m) and a timestamp. The streaming example triggers the top speed of each car every x meters elapsed for the last y seconds.
-
-
Constructor Summary
Constructors Constructor Description TopSpeedWindowing()
-