pyflink.datastream.formats.json.JsonRowDeserializationSchema#
- class JsonRowDeserializationSchema(j_deserialization_schema)[source]#
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.