org.apache.flink.streaming.examples.sideoutput

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 WindowWordCount that 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 and Description
static class	SideOutputExample.Tokenizer Implements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction.

Constructor Summary

Constructors

Constructor and Description
SideOutputExample()

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SideOutputExample

public SideOutputExample()

Method Detail

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception