Trait RowStream 

pub trait RowStream {
    type Columns<'a>: ColumnSliceSet<'a>
       where Self: 'a;

    // Required methods
    fn schema(&self) -> &Arc<Schema> ;
    fn next_chunk<'a>(
        &'a mut self,
    ) -> Result<Option<RowChunk<'a, Self::Columns<'a>>>, Error>;
}

Required Associated Types

type Columns<'a>: ColumnSliceSet<'a> where Self: 'a

Required Methods

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

fn next_chunk<'a>( &'a mut self, ) -> Result<Option<RowChunk<'a, Self::Columns<'a>>>, Error>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl<'storage, P, S> RowStream for ScanRowStream<'storage, P, S>

where P: Pager<Blob = EntryHandle> + Send + Sync, S: ScanStorage<P>,

type Columns<'a> = ColumnSlices<'a> where ScanRowStream<'storage, P, S>: 'a