pyflink.datastream.connectors.pulsar.PulsarSerializationSchema

class PulsarSerializationSchema(_j_pulsar_serialization_schema)

The serialization schema for how to serialize records into Pulsar.

Methods

flink_schema(serialization_schema)

Create a PulsarSerializationSchema by using the flink's SerializationSchema.