Trait RecordBatchStream 

pub trait RecordBatchStream: Stream<Item = Result<RecordBatch, DataFusionError>> {
    // Required method
    fn schema(&self) -> Arc<Schema>;
}

Trait for types that stream [RecordBatch]

See SendableRecordBatchStream for more details.

Required Methods

fn schema(&self) -> Arc<Schema>

Returns the schema of this RecordBatchStream.

Implementation of this trait should guarantee that all RecordBatch’s returned by this stream should have the same schema as returned from this method.

Implementors

impl RecordBatchStream for AggregateStream

impl RecordBatchStream for GroupedHashAggregateStream

impl RecordBatchStream for GroupedTopKAggregateStream

impl RecordBatchStream for CoalesceBatchesStream

impl RecordBatchStream for FilterExecStream

impl RecordBatchStream for HashJoinStream

impl RecordBatchStream for NestedLoopJoinStream

impl RecordBatchStream for ClassicPWMJStream

impl RecordBatchStream for SortMergeJoinStream

impl RecordBatchStream for LimitStream

impl RecordBatchStream for LazyMemoryStream

impl RecordBatchStream for MemoryStream

impl RecordBatchStream for ProjectionStream

impl RecordBatchStream for RecursiveQueryStream

impl RecordBatchStream for PerPartitionStream

impl RecordBatchStream for RepartitionStream

impl RecordBatchStream for StreamAttachedReservation

impl RecordBatchStream for PartialSortStream

impl RecordBatchStream for SpillReaderStream

impl RecordBatchStream for BatchSplitStream

impl RecordBatchStream for EmptyRecordBatchStream

impl RecordBatchStream for ObservedStream

impl RecordBatchStream for BlockingStream

impl RecordBatchStream for PanicStream

impl RecordBatchStream for TestStream

impl RecordBatchStream for CombinedRecordBatchStream

impl RecordBatchStream for UnnestStream

impl RecordBatchStream for BoundedWindowAggStream

impl RecordBatchStream for WindowAggStream

impl<C: CursorValues + Unpin> RecordBatchStream for SortPreservingMergeStream<C>

impl<S> RecordBatchStream for RecordBatchStreamAdapter<S>

where S: Stream<Item = Result<RecordBatch>>,

impl<T> RecordBatchStream for CooperativeStream<T>

where T: RecordBatchStream + Unpin,

impl<T: BatchTransformer + Unpin + Send> RecordBatchStream for CrossJoinStream<T>

impl<T: BatchTransformer + Unpin + Send> RecordBatchStream for SymmetricHashJoinStream<T>