write_rows_and_track_times

micromegas::analytics::lakehouse::write_partition

Function write_rows_and_track_times 

Source 
pub async fn write_rows_and_track_times(
    rb_stream: &mut Receiver<Result<PartitionRowSet, Error>>,
    arrow_writer: &mut AsyncArrowWriter<AsyncParquetWriter>,
    logger: &Arc<dyn Logger>,
    desc: &str,
) -> Result<Option<TimeRange>, Error>
Expand description

Writes rows from the stream and tracks event time ranges.