flow.record.adapter.avro
#
Module Contents#
Classes#
Functions#
Attributes#
- flow.record.adapter.avro.__usage__ = Multiline-String#
Show Value
""" Apache AVRO adapter --- Write usage: rdump -w avro://[PATH] Read usage: rdump avro://[PATH] [PATH]: path to file. Leave empty or "-" to output to stdout """
- flow.record.adapter.avro.AVRO_TYPE_MAP#
- flow.record.adapter.avro.RECORD_TYPE_MAP#
- flow.record.adapter.avro.EPOCH#
- class flow.record.adapter.avro.AvroWriter(path, key=None, **kwargs)#
Bases:
flow.record.adapter.AbstractWriter
- fp#
- writer#
- write(r)#
Write a record.
- flush()#
Flush any buffered writes.
- close()#
Close the Writer, no more writes will be possible.
- class flow.record.adapter.avro.AvroReader(path, selector=None, **kwargs)#
Bases:
flow.record.adapter.AbstractReader
- fp#
- __iter__()#
Return a record iterator.
- close()#
Close the Reader, can be overriden to properly free resources.
- flow.record.adapter.avro.descriptor_to_schema(desc)#
- flow.record.adapter.avro.schema_to_descriptor(schema)#
- flow.record.adapter.avro.avro_type_to_flow_type(ftype)#