public class WordCount extends Object
The input is a plain text file with lines separated by newline characters.
Usage:
WordCount --input <path> --output <path>
If no parameters are provided, the program is run with default data from
WordCountData
This example shows how to:
- write a simple Flink program. - use Tuple data types. - write and use user-defined functions.
Constructor and Description |
---|
WordCount() |
public static void main(String[] args)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.