Skip to main content

assignments_chunk

risingwave_stream::executor::source::iceberg_update::list

Function assignments_chunk 

Source 
fn assignments_chunk(
    assignments: &[IcebergUpdateAssignment],
) -> StreamExecutorResult<StreamChunk>