materialize_partition_range

micromegas::analytics::lakehouse::batch_update

Function materialize_partition_range 

Source 
pub fn materialize_partition_range(
    existing_partitions_all_views: Arc<PartitionCache>,
    lakehouse: Arc<LakehouseContext>,
    view: Arc<dyn View>,
    insert_range: TimeRange,
    partition_time_delta: TimeDelta,
    logger: Arc<dyn Logger>,
) -> impl Future<Output = Result<(), Error>>
Expand description

Materializes partitions within a given time range.