Module pyfx.api.avro
Utility functions to convert pandas DataFrames to avro.
Classes
class AvroStream (schema: Dict[str, Any], records_stream: Generator[Dict[str, Any], None, None])
-
Readable Avro Stream.
Static methods
def from_dataframe(dataframe: pandas.core.frame.DataFrame) ‑> AvroStream
-
Create an AvroStream from a pandas Dataframe.
Methods
def read(self, size: int) ‑> bytes
-
See
RawIOBase
corresponding method.