Skip to content

Commit

Permalink
fix doc links
Browse files Browse the repository at this point in the history
  • Loading branch information
alamb committed Jun 6, 2023
1 parent 01934b4 commit bd21382
Showing 1 changed file with 7 additions and 3 deletions.
10 changes: 7 additions & 3 deletions datafusion/core/src/physical_plan/stream.rs
Original file line number Diff line number Diff line change
Expand Up @@ -208,9 +208,13 @@ impl RecordBatchReceiverStreamBuilder {
}
}

/// Adapter for a tokio [`ReceiverStream`] that implements the
/// [`SendableRecordBatchStream`] interface and propagates panics and
/// errors. Use [`Self::builder`] to construct one.
/// A [`SendableRecordBatchStream`] that combines [`RecordBatch`]es from multiple inputs,
/// on new tokio Tasks, increasing the potential parallelism.
///
/// This structure also handles propagating panics and cancelling the
/// underlying tasks correctly.
///
/// Use [`Self::builder`] to construct one.
pub struct RecordBatchReceiverStream {
schema: SchemaRef,
inner: BoxStream<'static, Result<RecordBatch>>,
Expand Down

0 comments on commit bd21382

Please sign in to comment.