Class WindowWordCount
- java.lang.Object
-
- org.apache.flink.streaming.examples.windowing.WindowWordCount
-
public class WindowWordCount extends Object
Implements a windowed version of the streaming "WordCount" program.The input is a plain text file with lines separated by newline characters.
Usage:
WordCount --input <path> --output <path> --window <n> --slide <n>
If no parameters are provided, the program is run with default data fromWordCountData
.This example shows how to:
- write a simple Flink Streaming program,
- use tuple data types,
- use basic windowing abstractions.
-
-
Constructor Summary
Constructors Constructor Description WindowWordCount()
-