graviti.portex.avro

Code converting PyArrow schema to Avro Schema.

Module Contents

Classes

AvroSchema
AvroField
AvroPrimitiveSchema
AvroRecord
AvroArray
PortexEnum
PortexDate
PortexTime
PortexTimestamp
PortexTimedelta

Functions

convert_portex_schema_to_avro(portex_type)

class graviti.portex.avro.AvroSchema(name, namespace, portex_type)

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.base.PortexType) –

abstract to_json(self)

Return type

Dict[str, Any]

class graviti.portex.avro.AvroField(type_, name, *, optional=True, has_default=False, default=None)

Parameters

• type_ (AvroSchema) –

• name (str) –

• optional (bool) –

• has_default (bool) –

• default (Any) –

to_json(self)

Return type

Dict[str, Any]

class graviti.portex.avro.AvroPrimitiveSchema(name, namespace, portex_type)

Bases: AvroSchema

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.base.PortexType) –

to_json(self)

Return type

str

class graviti.portex.avro.AvroRecord(name, namespace, portex_type)

Bases: AvroSchema

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.builtin.record) –

to_json(self)

Return type

Dict[str, Any]

class graviti.portex.avro.AvroArray(name, namespace, portex_type)

Bases: AvroSchema

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.builtin.array) –

to_json(self)

Return type

Dict[str, Any]

class graviti.portex.avro.PortexEnum(name, namespace, portex_type)

Bases: AvroSchema

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.builtin.enum) –

to_json(self)

Return type

Dict[str, Any]

class graviti.portex.avro.PortexDate(name, namespace, portex_type)

Bases: AvroSchema

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.base.PortexType) –

to_json(self)

Return type

Dict[str, Any]

class graviti.portex.avro.PortexTime(name, namespace, portex_type)

Bases: AvroSchema

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.builtin.time) –

to_json(self)

Return type

Dict[str, Any]

class graviti.portex.avro.PortexTimestamp(name, namespace, portex_type)

Bases: AvroSchema

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.builtin.timestamp) –

to_json(self)

Return type

Dict[str, Any]

class graviti.portex.avro.PortexTimedelta(name, namespace, portex_type)

Bases: AvroSchema

Parameters

• name (str) –

• namespace (str) –

• portex_type (graviti.portex.builtin.timedelta) –

to_json(self)

Return type

Dict[str, Any]

graviti.portex.avro.convert_portex_schema_to_avro(portex_type)

Parameters

portex_type (graviti.portex.builtin.record) –

Return type

Dict[str, Any]