pulsar.functions.serde.IdentitySerDe

class documentation

class IdentitySerDe(SerDe): (source)

View In Hierarchy

Simple Serde that just conversion to string and back

Method __init__ Undocumented
Method deserialize Serialize input_bytes into an object
Method serialize Serialize input message into bytes
Instance Variable _types Undocumented
def __init__(self): (source)

Undocumented

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

_types = (source)

Undocumented