write_partition_from_rows

micromegas::analytics::lakehouse::write_partition

Function write_partition_from_rows 

Source 
pub async fn write_partition_from_rows(
    lake: Arc<DataLakeConnection>,
    view_metadata: ViewMetadata,
    file_schema: Arc<Schema>,
    insert_range: TimeRange,
    source_data_hash: Vec<u8>,
    rb_stream: Receiver<PartitionRowSet>,
    logger: Arc<dyn Logger>,
) -> Result<(), Error>
Expand description

Writes a partition to a Parquet file from a stream of PartitionRowSets.