org.apache.flink.streaming.util.serialization

Class JsonRowDeserializationSchema

java.lang.Object

org.apache.flink.formats.json.JsonRowDeserializationSchema

org.apache.flink.streaming.util.serialization.JsonRowDeserializationSchema

All Implemented Interfaces:

Serializable, DeserializationSchema<Row>, ResultTypeQueryable<Row>

Deprecated.

Please use JsonRowDeserializationSchema in the "flink-json" module.

@PublicEvolving
 @Deprecated
public class JsonRowDeserializationSchema
extends JsonRowDeserializationSchema

Deserialization schema from JSON to Row.

Deserializes the byte[] messages as a JSON object and reads the specified fields.

Failure during deserialization are forwarded as wrapped IOExceptions.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JsonRowDeserializationSchema(TypeInformation<Row> typeInfo) Deprecated. Please use JsonRowDeserializationSchema in the "flink-json" module.

Method Summary

Methods inherited from class org.apache.flink.formats.json.JsonRowDeserializationSchema

deserialize, getProducedType, isEndOfStream, setFailOnMissingField

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonRowDeserializationSchema

@Deprecated
public JsonRowDeserializationSchema(TypeInformation<Row> typeInfo)

Deprecated. Please use JsonRowDeserializationSchema in the "flink-json" module.

Creates a JSON deserialization schema for the given fields and types.

Parameters:

typeInfo - Type information describing the result type. The field names are used to parse the JSON file and so are the types.