risingwave_meta::stream::stream_graph::fragment

Function gen_output_mapping

Source 
fn gen_output_mapping(
    required_columns: &[PbColumnDesc],
    upstream_columns: &[PbColumnDesc],
) -> Option<DispatchOutputMapping>
Expand description

Generate the output_mapping for DispatchStrategy from given columns.