Skip to main content

task_row

risingwave_stream::executor::source::iceberg_update

Function task_row 

Source 
fn task_row(
    assignment: &IcebergUpdateAssignment,
    value: &impl Serialize,
) -> StreamExecutorResult<OwnedRow>