write_partition_from_blocks

micromegas::analytics::lakehouse::jit_partitions

Function write_partition_from_blocks 

Source 
pub fn write_partition_from_blocks(
    lake: Arc<DataLakeConnection>,
    view_metadata: ViewMetadata,
    schema: Arc<Schema>,
    source_data: SourceDataBlocksInMemory,
    block_processor: Arc<dyn BlockProcessor>,
) -> impl Future<Output = Result<(), Error>>
Expand description

Writes a partition from a set of blocks.