fetch_partition_source_data

micromegas::analytics::lakehouse::partition_source_data

Function fetch_partition_source_data 

Source 
pub async fn fetch_partition_source_data(
    lakehouse: Arc<LakehouseContext>,
    existing_partitions: Arc<PartitionCache>,
    insert_range: TimeRange,
    source_stream_tag: &str,
) -> Result<SourceDataBlocks, Error>
Expand description

Fetches partition source data from the data lake.