Struct ContinuousTableInput 

pub struct ContinuousTableInput { /* private fields */ }

Schema-bound producer handle for one continuous SQL table.

Implementations

impl ContinuousTableInput

pub fn schema(&self) -> &SchemaRef

Expected Arrow schema for every submitted batch.

pub fn try_send(&self, batch: RecordBatch) -> Result<(), ContinuousInputError>

Submit a batch without waiting for queue capacity.

pub async fn send(&self, batch: RecordBatch) -> Result<(), ContinuousInputError>

Submit a batch, asynchronously waiting for queue capacity.

pub fn close(&self) -> Result<bool, ContinuousInputError>

Close the input. The consumer observes end-of-stream after queued data.

Returns true when this call closed an open input and false when it was already closed.

pub fn cancel(&self)

A-8: hard-cancel the stream. Drops any queued batches in the channel before closing it, so the consumer sees an immediate end-of-stream without flushing. Idempotent.

pub fn is_closed(&self) -> Result<bool, ContinuousInputError>

Whether the producer side has been closed.

Trait Implementations

impl Debug for ContinuousTableInput

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.