risingwave_simulation::ctl_ext::predicate

Function root

Source 
fn root(fragment: &PbFragment) -> &StreamNode