Skip to main content

create_continuous_table_with_capacity

krishiv_sql::streaming

Function create_continuous_table_with_capacity 

Source 
pub fn create_continuous_table_with_capacity(
    schema: SchemaRef,
    capacity: usize,
) -> Result<(Arc<dyn TableProvider>, Arc<ContinuousTableInput>)>
Expand description

Same as create_continuous_table but with a caller-supplied capacity. Useful for tests that want to exercise the full/empty channel boundary without needing to push 64 batches.