risingwave_stream::config

Function chunk_size

source 
pub(crate) fn chunk_size() -> usize