Trait Input 

pub trait Input: Stream + Send {
    type InputId;

    // Required method
    fn id(&self) -> Self::InputId;

    // Provided method
    fn boxed_input(self) -> BoxedInput<Self::InputId, Self::Item>
       where Self: Sized + 'static { ... }
}

Input is a more abstract upstream input type, used for DynamicReceivers type handling of multiple upstream inputs

Required Associated Types

type InputId

Required Methods

fn id(&self) -> Self::InputId

The upstream input id.

Provided Methods

fn boxed_input(self) -> BoxedInput<Self::InputId, Self::Item>

where Self: Sized + 'static,

Implementors

impl Input for UnionExecutorInput

type InputId = usize

impl Input for SinkHandlerInput

type InputId = TypedId<risingwave_pb::::id::FragmentId::{constant#0}, u32>

impl Input for LocalInput

type InputId = TypedId<risingwave_pb::::id::ActorId::{constant#0}, u32>

impl Input for RemoteInput

type InputId = TypedId<risingwave_pb::::id::ActorId::{constant#0}, u32>