Type Alias ReceiverExecutor 

pub type ReceiverExecutor = MergeExecutorInner<BoxedActorInput>;

ReceiverExecutor receives data from a single upstream actor. It’s a special case of MergeExecutor with only one upstream.

Aliased Type

pub struct ReceiverExecutor {
    actor_context: Arc<ActorContext>,
    upstream: Pin<Box<dyn Input<Item = Result<MessageInner<()>, StreamExecutorError>, InputId = TypedId<6>>>>,
    fragment_id: TypedId<5>,
    upstream_fragment_id: TypedId<5>,
    local_barrier_manager: LocalBarrierManager,
    metrics: Arc<StreamingMetrics>,
    barrier_rx: UnboundedReceiver<BarrierInner<Option<Arc<Mutation>>>>,
}

Fields

actor_context: Arc<ActorContext>

The context of the actor.

upstream: Pin<Box<dyn Input<Item = Result<MessageInner<()>, StreamExecutorError>, InputId = TypedId<6>>>>

Upstream channels.

fragment_id: TypedId<5>

Belonged fragment id.

upstream_fragment_id: TypedId<5>

Upstream fragment id.

local_barrier_manager: LocalBarrierManager

metrics: Arc<StreamingMetrics>

Streaming metrics.

barrier_rx: UnboundedReceiver<BarrierInner<Option<Arc<Mutation>>>>