rewrite_stream_scan_and_merge

risingwave_meta::stream::stream_graph::fragment

Function rewrite_stream_scan_and_merge 

Source 
fn rewrite_stream_scan_and_merge(
    stream_scan_node: &mut StreamNode,
    removed_column_ids: &HashSet<ColumnId>,
    newly_added_columns: &[ColumnCatalog],
    upstream_table: &PbTable,
    upstream_table_fragment_id: FragmentId,
) -> MetaResult<ScanRewriteResult>
Expand description

Rewrite StreamScan + Merge to match the new upstream schema.