risingwave_stream::common::table::state_table

Trait KeyedRowStream

source 
pub trait KeyedRowStream<'a>: Stream<Item = StreamExecutorResult<KeyedRow<Bytes>>> + 'a { }

Implementors§

source§

impl<'a, T> KeyedRowStream<'a> for T
where T: Stream<Item = StreamExecutorResult<KeyedRow<Bytes>>> + 'a,