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

View In Hierarchy

Undocumented

Method	`__init__`	Undocumented
Method	`decode`	Undocumented
Method	`encode`	Undocumented
Method	`schema_info`	Undocumented
Method	`_validate_object_type`	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

@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

@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

_record_cls = (source) ¶

Undocumented

_schema_info = (source) ¶

Undocumented