Package org.apache.flink.streaming.examples.windowing
-
Class Summary Class Description GroupedProcessingTimeWindowExample An example of grouped stream windowing into sliding time windows.SessionWindowing An example of session windowing that keys events by ID and groups and counts them in session with gaps of 3 milliseconds.TopSpeedWindowing An example of grouped stream windowing where different eviction and trigger policies can be used.WindowWordCount Implements a windowed version of the streaming "WordCount" program.