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 |
---|---|
static class |
SideOutputExample.Tokenizer
Implements the string tokenizer that splits sentences into words as a
user-defined FlatMapFunction.
|
Constructor and Description |
---|
SideOutputExample() |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.