pulsar.schema.schema.Schema

class documentation

class Schema(object): (source)

Known subclasses: pulsar.schema.schema.BytesSchema, pulsar.schema.schema.JsonSchema, pulsar.schema.schema.StringSchema, pulsar.schema.schema_avro.AvroSchema, pulsar.schema.schema_protobuf.ProtobufNativeSchema

Constructor: Schema(record_cls, schema_type, schema_definition, schema_name)

View In Hierarchy

Undocumented

Method	`__init__`	Undocumented
Method	`attach_client`	Undocumented
Method	`decode`	Undocumented
Method	`decode_message`	Undocumented
Method	`encode`	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_type, schema_definition, schema_name): (source) ¶

overridden in pulsar.schema.schema.BytesSchema, pulsar.schema.schema.JsonSchema, pulsar.schema.schema.StringSchema, pulsar.schema.schema_avro.AvroSchema, pulsar.schema.schema_protobuf.ProtobufNativeSchema

Undocumented

def attach_client(self, client: _pulsar.Client): (source) ¶

Undocumented

@abstractmethod

def decode(self, data): (source) ¶

Undocumented

def decode_message(self, msg: _pulsar.Message): (source) ¶

overridden in pulsar.schema.schema_avro.AvroSchema

Undocumented

@abstractmethod

def encode(self, obj): (source) ¶

Undocumented