Skip to main content

split_write_batches

risingwave_connector::sink::firestore

Function split_write_batches 

Source 
fn split_write_batches(writes: Vec<Write>, max_count: usize) -> Vec<Vec<Write>>