public class WordCountPojo extends Object
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 |
WordCountPojo.Tokenizer
Implements the string tokenizer that splits sentences into words as a user-defined
FlatMapFunction.
|
static class |
WordCountPojo.Word
This is the POJO (Plain Old Java Object) that is being used for all the operations.
|
Constructor and Description |
---|
WordCountPojo() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.