Function decode 

fn decode<T: DeserializeOwned>(
    row: impl Row,
    assignment: impl FnOnce(&T) -> &IcebergUpdateAssignment,
) -> StreamExecutorResult<T>

Decodes the JSON value of a task row and checks it against the row key.