pulsar.functions.serde.PickleSerDe

class documentation

class PickleSerDe(SerDe): (source)

View In Hierarchy

Pickle based serializer

Method deserialize Serialize input_bytes into an object
Method serialize Serialize input message into bytes
def deserialize(self, input_bytes): (source)
overrides pulsar.functions.serde.SerDe.deserialize

Serialize input_bytes into an object

def serialize(self, input): (source)
overrides pulsar.functions.serde.SerDe.serialize

Serialize input message into bytes