uni_plugin::adapter_common::batch_builder

Function batch_into_stream

pub fn batch_into_stream(batch: RecordBatch) -> SendableRecordBatchStream

Expand description

Wrap a single RecordBatch in a one-item SendableRecordBatchStream.

Used by procedure adapters whose plugin produced exactly one batch (and by tests that need a stream-shaped fixture for a one-row constant input). The yielded schema is Arc-cloned from the supplied batch.

batch_into_stream

Function batch_into_stream Copy item path

Function batch_into_stream