pyflink.datastream.connectors.pulsar.PulsarDeserializationSchema

class PulsarDeserializationSchema(_j_pulsar_deserialization_schema)

A schema bridge for deserializing the pulsar’s Message into a flink managed instance. We support both the pulsar’s self managed schema and flink managed schema.

Methods

flink_schema(deserialization_schema)	Create a PulsarDeserializationSchema by using the flink's DeserializationSchema.
flink_type_info(type_information[, ...])	Create a PulsarDeserializationSchema by using the given TypeInformation.