pulsar.functions.serde.SerDe

class documentation

class SerDe(object): (source)

Known subclasses: pulsar.functions.serde.IdentitySerDe, pulsar.functions.serde.PickleSerDe

View In Hierarchy

Interface for Serialization/Deserialization

Method deserialize Serialize input_bytes into an object
Method serialize Serialize input message into bytes
@abstractmethod
def deserialize(self, input_bytes): (source)
overridden in pulsar.functions.serde.IdentitySerDe, pulsar.functions.serde.PickleSerDe

Serialize input_bytes into an object

@abstractmethod
def serialize(self, input): (source)
overridden in pulsar.functions.serde.IdentitySerDe, pulsar.functions.serde.PickleSerDe

Serialize input message into bytes