Package org.apache.flink.formats.json

Class JsonRowDeserializationSchema

java.lang.Object

org.apache.flink.formats.json.JsonRowDeserializationSchema

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.types.Row>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.types.Row>

@PublicEvolving
@Deprecated
public class JsonRowDeserializationSchema
extends Object
implements org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.types.Row>

Deprecated.

The format was developed for the Table API users and will not be maintained for DataStream API users anymore. Either use Table API or switch to Data Stream, defining your own DeserializationSchema.

Deserialization schema from JSON to Flink types.

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

Failures during deserialization are forwarded as wrapped IOExceptions.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JsonRowDeserializationSchema.Builder	Deprecated. Builder for JsonRowDeserializationSchema.

Nested classes/interfaces inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema

org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext

Constructor Summary

Constructors

Constructor	Description
JsonRowDeserializationSchema(String jsonSchema)	Deprecated. Use the provided JsonRowDeserializationSchema.Builder instead.
JsonRowDeserializationSchema(org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> typeInfo)	Deprecated. Use the provided JsonRowDeserializationSchema.Builder instead.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.types.Row	deserialize(byte[] message)	Deprecated.
boolean	equals(Object o)	Deprecated.
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row>	getProducedType()	Deprecated.
int	hashCode()	Deprecated.
boolean	isEndOfStream(org.apache.flink.types.Row nextElement)	Deprecated.
void	open(org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext context)	Deprecated.
void	setFailOnMissingField(boolean failOnMissingField)	Deprecated. Use the provided JsonRowDeserializationSchema.Builder instead.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.common.serialization.DeserializationSchema

deserialize

Constructor Detail

JsonRowDeserializationSchema

@Deprecated
public JsonRowDeserializationSchema(org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> typeInfo)

Deprecated.

Use the provided JsonRowDeserializationSchema.Builder instead.

JsonRowDeserializationSchema

@Deprecated
public JsonRowDeserializationSchema(String jsonSchema)

Deprecated.

Use the provided JsonRowDeserializationSchema.Builder instead.

Method Detail

open

public void open(org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext context)
          throws Exception

Deprecated.

Specified by:

open in interface org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.types.Row>

Throws:

Exception

setFailOnMissingField

@Deprecated
public void setFailOnMissingField(boolean failOnMissingField)

Deprecated.

Use the provided JsonRowDeserializationSchema.Builder instead.

deserialize

public org.apache.flink.types.Row deserialize(byte[] message)
                                       throws IOException

Deprecated.

Specified by:

deserialize in interface org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.types.Row>

Throws:

IOException

isEndOfStream

public boolean isEndOfStream(org.apache.flink.types.Row nextElement)

Deprecated.

Specified by:

isEndOfStream in interface org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.types.Row>

getProducedType

public org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.types.Row> getProducedType()

Deprecated.

Specified by:

getProducedType in interface org.apache.flink.api.java.typeutils.ResultTypeQueryable<org.apache.flink.types.Row>

equals

public boolean equals(Object o)

Deprecated.

Overrides:

equals in class Object

hashCode

public int hashCode()

Deprecated.

Overrides:

hashCode in class Object