pyflink.datastream.formats.json.JsonRowDeserializationSchema

class JsonRowDeserializationSchema(j_deserialization_schema)

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.

Methods

builder()

A static method to get a Builder for JsonRowDeserializationSchema.