pyflink.datastream.connectors.pulsar.PulsarSerializationSchema# class PulsarSerializationSchema(_j_pulsar_serialization_schema)[source]# The serialization schema for how to serialize records into Pulsar. Methods flink_schema(serialization_schema) Create a PulsarSerializationSchema by using the flink's SerializationSchema.