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

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

Undocumented

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

Undocumented

@abstractmethod
def decode(self, data): (source)
overridden in pulsar.schema.schema.BytesSchema, pulsar.schema.schema.JsonSchema, pulsar.schema.schema.StringSchema, pulsar.schema.schema_avro.AvroSchema

Undocumented

def decode_message(self, msg: _pulsar.Message): (source)
overridden in pulsar.schema.schema_avro.AvroSchema

Undocumented

@abstractmethod
def encode(self, obj): (source)
overridden in pulsar.schema.schema.BytesSchema, pulsar.schema.schema.JsonSchema, pulsar.schema.schema.StringSchema, pulsar.schema.schema_avro.AvroSchema

Undocumented

def schema_info(self): (source)

Undocumented

def _validate_object_type(self, obj): (source)

Undocumented

_client = (source)

Undocumented

_record_cls = (source)

Undocumented

_schema_info = (source)

Undocumented