risingwave_stream::executor::exchange::input

Function new_input

source 
pub(crate) fn new_input(
    context: &SharedContext,
    metrics: Arc<StreamingMetrics>,
    actor_id: ActorId,
    fragment_id: FragmentId,
    upstream_actor_id: ActorId,
    upstream_fragment_id: FragmentId,
) -> StreamResult<BoxedInput>
Expand description

Create a LocalInput or RemoteInput instance with given info. Used by merge executors and receiver executors.