Module writer
Source - MetadataArgs
- Holds all the arguments required to metadata for the output file.
- ParquetDataRow 🔒
- Represents a row of data in the Parquet file format.
Fields used depend on the measurement type and configuration.
- WriteConfig
- Configuration for the results writing process.
- BATCH_SIZE 🔒
- build_parquet_schema 🔒
- Creates a parquet data schema from the headers based on the measurement type and configuration.
- calculate_rtt
- get_csv_metadata
- Returns a vector of lines containing the metadata of the measurement
- get_header
- Creates the appropriate CSV header for the results file (based on the measurement type)
- get_parquet_metadata
- Returns a vector of key-value pairs containing the metadata of the measurement.
- get_row 🔒
- Get the result (csv row) from a Reply message
- reply_to_parquet_row 🔒
- Converts a Reply message into a ParquetDataRow for writing to a Parquet file.
- write_batch_to_parquet 🔒
- Writes a batch of ParquetDataRow to the Parquet file using the provided writer.
- write_results
- Writes the results to a file (and optionally to the command-line)
- write_results_parquet
- Write results to a Parquet file as they are received from the channel.
This function processes the results in batches to optimize writing performance.