Skip to main content

pending_tasks

risingwave_stream::executor::source::iceberg_update::fetch

Function pending_tasks 

Source 
pub(super) async fn pending_tasks<S: StateStore>(
    state: &SourceStateTableHandler<S>,
    job_id: u32,
    limit: usize,
    columns: &[ColumnCatalog],
    key_indices: &[usize],
) -> StreamExecutorResult<Vec<IcebergUpdateFetchState>>