org.apache.flink.examples.java.wordcount

Class WordCountPojo.Tokenizer

java.lang.Object

org.apache.flink.examples.java.wordcount.WordCountPojo.Tokenizer

All Implemented Interfaces:

Serializable, FlatMapFunction<String,WordCountPojo.Word>, Function

Enclosing class:

WordCountPojo

public static final class WordCountPojo.Tokenizer
extends Object
implements 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 and Description
Tokenizer()

Method Summary

Modifier and Type	Method and Description
void	flatMap(String value, Collector<WordCountPojo.Word> out) The core method of the FlatMapFunction.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Tokenizer

public Tokenizer()

Method Detail

flatMap

public void flatMap(String value,
                    Collector<WordCountPojo.Word> out)

Description copied from interface: FlatMapFunction

The core method of the FlatMapFunction. Takes an element from the input data set and transforms it into zero, one, or more elements.

Specified by:

flatMap in interface FlatMapFunction<String,WordCountPojo.Word>

Parameters:

value - The input value.

out - The collector for returning result values.