fn raise_key_value_errors(
    _: KV
) -> Option<Result<(Option<Row>, Row), DataflowError>>
Expand description

Handle possibly missing key or value portions of messages