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.