`flow.record.adapter`¶

Submodules¶

Package Contents¶

Classes¶

`AbstractWriter`
`AbstractReader`

Attributes¶

flow.record.adapter.__path__¶

class flow.record.adapter.AbstractWriter¶

abstract write(rec: flow.record.base.Record) → None¶: Write a record.

abstract flush() → None¶: Flush any buffered writes.

abstract close() → None¶: Close the Writer, no more writes will be possible.

__del__() → None¶

__enter__() → AbstractWriter¶

__exit__(*args) → None¶

class flow.record.adapter.AbstractReader¶

abstract __iter__() → collections.abc.Iterator[flow.record.base.Record]¶: Return a record iterator.

close() → None¶: Close the Reader, can be overriden to properly free resources.

__enter__() → AbstractReader¶

__exit__(*args) → None¶