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:
Note: All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API. This class is retained for testing purposes.
Modifier and Type | Class and Description |
---|---|
static class |
WordCount.Tokenizer
Implements the string tokenizer that splits sentences into words as a user-defined
FlatMapFunction.
|
Constructor and Description |
---|
WordCount() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.