ParquetReporter

class eclypse.report.reporters.parquet.ParquetReporter

Bases: Reporter

Class to report simulation metrics in partitioned Parquet files.

Methods

__init__(report_path)	Initialize the Parquet reporter.
init()	Initialize the reporter and import polars lazily.
report(event_name, event_idx, callback)	Report callback values as row dictionaries suitable for Parquet.
write(callback_type, data)	Write a batch of callback rows to a parquet part file.

__init__(report_path)

Initialize the Parquet reporter.

Parameters:

report_path (str | Path)

async init()

Initialize the reporter and import polars lazily.

report(event_name, event_idx, callback)

Report callback values as row dictionaries suitable for Parquet.

Parameters:

• event_name (str)

• event_idx (int)

• callback (EclypseEvent)

Return type:

Generator[dict[str, Any], None, None]

async write(callback_type, data)

Write a batch of callback rows to a parquet part file.

Parameters:

• callback_type (str)

• data (list[dict[str, Any]])