pub fn create_continuous_table(
schema: SchemaRef,
) -> Result<(Arc<dyn TableProvider>, Arc<ContinuousTableInput>)>Expand description
Creates a new continuous-table provider and its schema-bound producer.
The channel is bounded (capacity
CONTINUOUS_TABLE_CHANNEL_CAPACITY) so a slow DataFusion consumer
applies backpressure via ContinuousTableInput::send, or
ContinuousTableInput::try_send returns a resource-exhausted error.