risingwave_common::config::default::streaming

Function in_flight_barrier_nums

source 
pub fn in_flight_barrier_nums() -> usize