Function write_results_parquet

Source
pub fn write_results_parquet(
    rx: UnboundedReceiver<TaskResult>,
    config: WriteConfig<'_>,
)
Expand description

Write results to a Parquet file as they are received from the channel. This function processes the results in batches to optimize writing performance.

ยงArguments

  • rx - The receiver channel that receives the results.

  • config - The configuration for writing results, including file handle, metadata, and measurement type.

  • metadata_args - Arguments for generating metadata, including measurement type, origins, and configurations.