org.apache.flink.streaming.connectors.twitter

Class TwitterStreaming.SelectDataFlatMap

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,Tuple5<Long,Integer,String,String,String>>

org.apache.flink.streaming.connectors.twitter.TwitterStreaming.SelectDataFlatMap

All Implemented Interfaces:

Serializable, FlatMapFunction<String,Tuple5<Long,Integer,String,String,String>>, Function, RichFunction

Enclosing class:

TwitterStreaming

public static class TwitterStreaming.SelectDataFlatMap
extends JSONParseFlatMap<String,Tuple5<Long,Integer,String,String,String>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SelectDataFlatMap()

Method Summary

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

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

SelectDataFlatMap

public SelectDataFlatMap()

Method Detail

flatMap

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

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,Tuple5<Long,Integer,String,String,String>>

Specified by:

flatMap in class RichFlatMapFunction<String,Tuple5<Long,Integer,String,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.