Class WordCountPojo.Tokenizer
- java.lang.Object
-
- org.apache.flink.examples.java.wordcount.WordCountPojo.Tokenizer
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.FlatMapFunction<String,WordCountPojo.Word>,org.apache.flink.api.common.functions.Function
- Enclosing class:
- WordCountPojo
public static final class WordCountPojo.Tokenizer extends Object implements org.apache.flink.api.common.functions.FlatMapFunction<String,WordCountPojo.Word>
Implements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction. The function takes a line (String) and splits it into multiple Word objects.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description Tokenizer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidflatMap(String value, org.apache.flink.util.Collector<WordCountPojo.Word> out)
-
-
-
Method Detail
-
flatMap
public void flatMap(String value, org.apache.flink.util.Collector<WordCountPojo.Word> out)
- Specified by:
flatMapin interfaceorg.apache.flink.api.common.functions.FlatMapFunction<String,WordCountPojo.Word>
-
-