Skip to main content

forward_record_batches

query::datafusion

Function forward_record_batches 

Source 
async fn forward_record_batches(
    stream: SendableRecordBatchStream,
    batch_tx: UnboundedSender<Result<RecordBatch>>,
) -> Result<()>