Class | Description |
---|---|
GroupedProcessingTimeWindowExample | |
GroupedProcessingTimeWindowExample.FirstFieldKeyExtractor<Type extends Tuple,Key> | |
GroupedProcessingTimeWindowExample.SummingReducer | |
GroupedProcessingTimeWindowExample.SummingWindowFunction | |
SessionWindowing | |
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–2017 The Apache Software Foundation. All rights reserved.