risingwave_storage::table

Trait TableIter

source
pub trait TableIter: Send {
    // Required method
    async fn next_row(&mut self) -> StorageResult<Option<OwnedRow>>;
}

Required Methods§

source

async fn next_row(&mut self) -> StorageResult<Option<OwnedRow>>

Object Safety§

This trait is not object safe.

Implementors§

source§

impl<S: Stream<Item = StorageResult<OwnedRow>> + Send + Unpin> TableIter for S

The row iterator of the storage table. The wrapper of stream item StorageResult<OwnedRow> if pk is not persisted.