org.apache.flink.streaming.connectors.twitter

Class TwitterTopology.SelectLanguageFlatMap

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.api.common.functions.RichFlatMapFunction<IN,OUT>

org.apache.flink.streaming.connectors.json.JSONParseFlatMap<String,String>

org.apache.flink.streaming.connectors.twitter.TwitterTopology.SelectLanguageFlatMap

All Implemented Interfaces:

Serializable, FlatMapFunction<String,String>, Function, RichFunction

Enclosing class:

TwitterTopology

public static class TwitterTopology.SelectLanguageFlatMap
extends JSONParseFlatMap<String,String>

FlatMapFunction to determine the language of tweets if possible

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SelectLanguageFlatMap()

Method Summary

Modifier and Type	Method and Description
void	flatMap(String value, Collector<String> out) Select the language from the incoming JSON text

Methods inherited from class org.apache.flink.streaming.connectors.json.JSONParseFlatMap

get, getBoolean, getDouble, getInt, getLong, getString

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

SelectLanguageFlatMap

public SelectLanguageFlatMap()

Method Detail

flatMap

public void flatMap(String value,
                    Collector<String> out)
             throws Exception

Select the language from the incoming JSON text

Specified by:

flatMap in interface FlatMapFunction<String,String>

Specified by:

flatMap in class RichFlatMapFunction<String,String>

Parameters:

value - The input value.

out - The collector for returning result values.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.