Skip to main content

find_stream_from_view

Function find_stream_from_view 

Source
pub fn find_stream_from_view(
    lakehouse: Arc<LakehouseContext>,
    view_factory: Arc<ViewFactory>,
    stream_id: &Uuid,
    query_range: Option<TimeRange>,
) -> impl Future<Output = Result<StreamMetadata, Error>>
Expand description

Finds a stream and its metadata using DataFusion (reads the streams view).