Skip to main content

lookup_index_rows

risingwave_stream::executor::iceberg_with_pk_index::writer

Function lookup_index_rows 

Source 
async fn lookup_index_rows<S: StateStore>(
    table: &StateTable<S>,
    pks: &[Project<'_, RowRef<'_>>],
    concurrency: usize,
) -> StreamExecutorResult<Vec<Option<OwnedRow>>>
Expand description

Looks up the PK index rows of pks with at most concurrency lookups in flight. Results are returned in the same order as pks.