org.apache.flink.streaming.connectors.json

Class JSONParseFlatMap<IN,OUT>

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<IN,OUT>

Type Parameters:

IN - Type of the input elements.

OUT - Type of the returned elements.

All Implemented Interfaces:

Serializable, FlatMapFunction<IN,OUT>, Function, RichFunction

Direct Known Subclasses:

TwitterStream.SelectEnglishAndTokenizeFlatMap, TwitterStreaming.SelectDataFlatMap, TwitterTopology.SelectLanguageFlatMap

public abstract class JSONParseFlatMap<IN,OUT>
extends RichFlatMapFunction<IN,OUT>

Abstract class derived from RichFlatMapFunction to handle JSON files.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JSONParseFlatMap()

Method Summary

Modifier and Type	Method and Description
Object	get(String jsonText, String field) Get the value object associated with a key form a JSON code.
boolean	getBoolean(String jsonText, String field) Get the boolean value associated with a key form a JSON code.
double	getDouble(String jsonText, String field) Get the double value associated with a key form a JSON code.
int	getInt(String jsonText, String field) Get the int value associated with a key form a JSON code.
long	getLong(String jsonText, String field) Get the long value associated with a key form a JSON code.
String	getString(String jsonText, String field) Get the String value associated with a key form a JSON code.

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

flatMap

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

JSONParseFlatMap

public JSONParseFlatMap()

Method Detail

get

public Object get(String jsonText,
                  String field)
           throws org.apache.sling.commons.json.JSONException

Get the value object associated with a key form a JSON code. It can find embedded fields, too.

Parameters:

jsonText - JSON String in which the field is searched.

field - The key whose value is searched for.

Returns:

The object associated with the field.

Throws:

org.apache.sling.commons.json.JSONException - If the field is not found.

getBoolean

public boolean getBoolean(String jsonText,
                          String field)
                   throws org.apache.sling.commons.json.JSONException

Get the boolean value associated with a key form a JSON code. It can find embedded fields, too.

Parameters:

jsonText - JSON String in which the field is searched.

field - The key whose value is searched for.

Returns:

The object associated with the field.

Throws:

org.apache.sling.commons.json.JSONException - If the field is not found.

getDouble

public double getDouble(String jsonText,
                        String field)
                 throws org.apache.sling.commons.json.JSONException

Get the double value associated with a key form a JSON code. It can find embedded fields, too.

Parameters:

jsonText - JSON String in which the field is searched.

field - The key whose value is searched for.

Returns:

The object associated with the field.

Throws:

org.apache.sling.commons.json.JSONException - If the field is not found.

getInt

public int getInt(String jsonText,
                  String field)
           throws org.apache.sling.commons.json.JSONException

Get the int value associated with a key form a JSON code. It can find embedded fields, too.

Parameters:

jsonText - JSON String in which the field is searched.

field - The key whose value is searched for.

Returns:

The object associated with the field.

Throws:

org.apache.sling.commons.json.JSONException - If the field is not found.

getLong

public long getLong(String jsonText,
                    String field)
             throws org.apache.sling.commons.json.JSONException

Get the long value associated with a key form a JSON code. It can find embedded fields, too.

Parameters:

jsonText - JSON String in which the field is searched.

field - The key whose value is searched for.

Returns:

The object associated with the field.

Throws:

org.apache.sling.commons.json.JSONException - If the field is not found.

getString

public String getString(String jsonText,
                        String field)
                 throws org.apache.sling.commons.json.JSONException

Get the String value associated with a key form a JSON code. It can find embedded fields, too.

Parameters:

jsonText - JSON String in which the field is searched.

field - The key whose value is searched for.

Returns:

The object associated with the field.

Throws:

org.apache.sling.commons.json.JSONException - If the field is not found.