Class SideOutputExample
- java.lang.Object
-
- org.apache.flink.streaming.examples.sideoutput.SideOutputExample
-
public class SideOutputExample extends Object
An example that illustrates the use of side output.This is a modified version of
WindowWordCountthat has a filter in the tokenizer and only emits some words for counting while emitting the other words to a side output.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classSideOutputExample.TokenizerImplements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction.
-
Constructor Summary
Constructors Constructor Description SideOutputExample()
-