Upstream

risingwave_stream::executor::merge::upstream

Trait Upstream 

Source 
pub trait Upstream:
    Stream<Item = StreamExecutorResult<DispatcherMessage>>
    + Unpin
    + Send
    + 'static {
    // Required methods
    fn upstream_input_ids(&self) -> impl Iterator<Item = ActorId> + '_;
    fn flush_buffered_watermarks(&mut self);
    fn update(
        &mut self,
        to_add: Vec<BoxedActorInput>,
        to_remove: &HashSet<ActorId>,
    );
}
Expand description

Trait unifying operations on MergeUpstream and SingletonUpstream, so that we can reuse code between MergeExecutor and ReceiverExecutor.

Required Methods§

Source

fn upstream_input_ids(&self) -> impl Iterator<Item = ActorId> + '_

Source

fn flush_buffered_watermarks(&mut self)

Source

fn update(&mut self, to_add: Vec<BoxedActorInput>, to_remove: &HashSet<ActorId>)

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§