Do you mean periodically flushing a queue of logs into a new parquet file (e.g. named with a timestamp)?
Do you mean periodically flushing a queue of logs into a new parquet file (e.g. named with a timestamp)?