public class SideOutputExample extends Object
This is a modified version of
WindowWordCount that has a filter in the tokenizer
and only emits some words for counting while emitting the other words to a side output.
|Modifier and Type||Class and Description|
Implements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction.
|Constructor and Description|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.