write_partition_from_blocks

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_processors: Arc<HashMap<&'static str, Arc<dyn BlockProcessor>>>,
) -> impl Future<Output = Result<(), Error>>
Expand description

Writes a partition from a set of blocks.

block_processors keys per-block dispatch on the source block’s format; see BlockPartitionSpec::write for the unknown-format behavior.