rewrite_project_node

risingwave_meta::stream::stream_graph::fragment

Function rewrite_project_node 

Source 
fn rewrite_project_node(
    project_node: &mut StreamNode,
    scan_rewrite: &ScanRewriteResult,
    newly_added_columns: &[ColumnCatalog],
    removed_column_ids: &HashSet<ColumnId>,
    upstream_table_name: &str,
) -> MetaResult<()>
Expand description

Rewrite Project node input refs and extend with newly added columns.