pulsar.schema.schema_avro.AvroSchema

class documentation

class AvroSchema(Schema): (source)

Constructor: AvroSchema(record_cls, schema_definition)

View In Hierarchy

Undocumented

Method __init__ Undocumented
Method decode Undocumented
Method decode_message Undocumented
Method encode Undocumented
Method encode_dict Undocumented
Method _decode_bytes Undocumented
Method _get_serialized_value Undocumented
Method _get_writer_schema Undocumented
Instance Variable _logger Undocumented
Instance Variable _schema Undocumented
Instance Variable _writer_schemas Undocumented

Inherited from Schema:

Method attach_client Undocumented
Method schema_info Undocumented
Method _validate_object_type Undocumented
Instance Variable _client Undocumented
Instance Variable _record_cls Undocumented
Instance Variable _schema_info Undocumented
def __init__(self, record_cls, schema_definition=None): (source)
overrides pulsar.schema.schema.Schema.__init__

Undocumented

def decode(self, data): (source)
overrides pulsar.schema.schema.Schema.decode

Undocumented

def decode_message(self, msg: _pulsar.Message): (source)
overrides pulsar.schema.schema.Schema.decode_message

Undocumented

def encode(self, obj): (source)
overrides pulsar.schema.schema.Schema.encode

Undocumented

def encode_dict(self, d): (source)

Undocumented

def _decode_bytes(self, data: bytes, writer_schema: dict): (source)

Undocumented

def _get_serialized_value(self, x): (source)

Undocumented

def _get_writer_schema(self, topic: str, version: int) -> dict: (source)

Undocumented

_logger = (source)

Undocumented

_schema = (source)

Undocumented

_writer_schemas = (source)

Undocumented