pyflink.common.serialization.JsonRowSerializationSchema

class JsonRowSerializationSchema(j_serialization_schema)

Serialization schema that serializes an object of Flink types into a JSON bytes. Serializes the input Flink object into a JSON string and converts it into byte[].

Result byte[] message can be deserialized using JsonRowDeserializationSchema.

Methods

builder()