risingwave_common::config::default::streaming

Function in_flight_barrier_nums

Source 
pub fn in_flight_barrier_nums() -> usize