Class 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 from WordCountData.

    This example shows how to:

    • write a simple Flink Streaming program,
    • use tuple data types,
    • use basic windowing abstractions.
    • Constructor Detail

      • WindowWordCount

        public WindowWordCount()