risingwave_stream::executor::exchange::output

Function new_output

source
pub fn new_output(
    context: &SharedContext,
    actor_id: ActorId,
    down_id: ActorId,
) -> StreamResult<BoxedOutput>
Expand description

Create a LocalOutput or RemoteOutput instance for the current actor id and the downstream actor id. Used by dispatchers.