risingwave_stream::executor::backfill::utils

Function create_builder

source 
pub fn create_builder(
    rate_limit: Option<usize>,
    chunk_size: usize,
    data_types: Vec<DataType>,
) -> DataChunkBuilder
Expand description

Creates a data chunk builder for snapshot read. If the rate_limit is smaller than chunk_size, it will take precedence. This is so we can partition snapshot read into smaller chunks than chunk size.