risingwave_stream::executor::exchange::input

Function new_input

Source 
pub(crate) async fn new_input(
    local_barrier_manager: &LocalBarrierManager,
    metrics: Arc<StreamingMetrics>,
    actor_id: ActorId,
    fragment_id: FragmentId,
    upstream_actor_info: &ActorInfo,
    upstream_fragment_id: FragmentId,
) -> StreamExecutorResult<BoxedInput>
Expand description

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