graviti.portex.avro#

Code converting PyArrow schema to Avro Schema.

Module Contents#

Classes#

AvroSchema

AvroField

AvroPrimitiveSchema

AvroRecordSchema

AvroArraySchema

AvroFixedArraySchema

AvroEnumSchema

Functions#

convert_portex_schema_to_avro(_schema)

class graviti.portex.avro.AvroSchema[source]#
to_json(self)[source]#
class graviti.portex.avro.AvroField(name_registry, typ, name, index, optional=True, has_default=False, default=None)[source]#
Parameters

typ (AvroSchema) –

to_json(self)[source]#
class graviti.portex.avro.AvroPrimitiveSchema(typ, has_default=False, default=None)[source]#

Bases: AvroSchema

to_json(self)[source]#
class graviti.portex.avro.AvroRecordSchema(name_registry, name, namespace, fields, aliases=None)[source]#

Bases: AvroSchema

Parameters

fields ([]) –

to_json(self)[source]#
class graviti.portex.avro.AvroArraySchema(items)[source]#

Bases: AvroSchema

Parameters

items (AvroSchema) –

to_json(self)[source]#
class graviti.portex.avro.AvroFixedArraySchema(items, shape)[source]#

Bases: AvroSchema

Parameters

items (AvroSchema) –

to_json(self)[source]#
class graviti.portex.avro.AvroEnumSchema(namespace, name, symbols)[source]#

Bases: AvroSchema

to_json(self)[source]#
graviti.portex.avro.convert_portex_schema_to_avro(_schema)[source]#
Parameters

_schema (graviti.portex.builtin.record) –