Trait RecordBatchStream

pub trait RecordBatchStream: Stream<Item = Result<RecordBatch>> {
    // Required methods
    fn schema(&self) -> SchemaRef;
    fn output_ordering(&self) -> Option<&[OrderOption]>;
    fn metrics(&self) -> Option<RecordBatchMetrics>;

    // Provided method
    fn name(&self) -> &str { ... }
}

Required Methods

fn schema(&self) -> SchemaRef

fn output_ordering(&self) -> Option<&[OrderOption]>

fn metrics(&self) -> Option<RecordBatchMetrics>

Provided Methods

fn name(&self) -> &str

Implementors

impl RecordBatchStream for AsyncRecordBatchStreamAdapter

impl RecordBatchStream for RecordBatchStreamAdapter

impl RecordBatchStream for EmptyRecordBatchStream

impl RecordBatchStream for SimpleRecordBatchStream

impl RecordBatchStream for ChainedRecordBatchStream

impl<S: Stream<Item = Result<RecordBatch>> + Unpin> RecordBatchStream for RecordBatchStreamWrapper<S>