flow.record.adapter.stream
#
Module Contents#
Classes#
Attributes#
- flow.record.adapter.stream.__usage__ = Multiline-String#
Show Value
""" Binary stream adapter (default adapter if none are specified) --- Write usage: rdump -w stream://[PATH] Read usage: rdump stream://[PATH] [PATH]: path to file. Leave empty or "-" to output to stdout """
- class flow.record.adapter.stream.StreamWriter(path: str, clobber=True, **kwargs)#
Bases:
flow.record.adapter.AbstractWriter
- fp#
- stream#
- write(record: flow.record.Record) None #
Write a record.
- flush() None #
Flush any buffered writes.
- close() None #
Close the Writer, no more writes will be possible.
- class flow.record.adapter.stream.StreamReader(path: str, selector: str | flow.record.selector.Selector = None, **kwargs)#
Bases:
flow.record.adapter.AbstractReader
- fp#
- stream#
- __iter__() Iterator[flow.record.Record] #
Return a record iterator.
- close() None #
Close the Reader, can be overriden to properly free resources.