graviti.portex.avro
#
Code converting PyArrow schema to Avro Schema.
Module Contents#
Classes#
Functions#
|
- class graviti.portex.avro.AvroField(name_registry, typ, name, optional=True, has_default=False, default=None)[source]#
- Parameters
typ (AvroSchema) –
- class graviti.portex.avro.AvroPrimitiveSchema(typ, has_default=False, default=None)[source]#
Bases:
AvroSchema
- class graviti.portex.avro.AvroRecordSchema(name_registry, name, namespace, fields, aliases=None)[source]#
Bases:
AvroSchema
- Parameters
fields ([]) –
- class graviti.portex.avro.AvroArraySchema(items)[source]#
Bases:
AvroSchema
- Parameters
items (AvroSchema) –
- class graviti.portex.avro.AvroEnumSchema(values)[source]#
Bases:
AvroSchema
- graviti.portex.avro.convert_portex_schema_to_avro(_schema)[source]#
- Parameters
_schema (graviti.portex.builtin.record) –