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.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.