Type Alias PbStreamActor

pub type PbStreamActor = StreamActor;

Alias for StreamActor.

Aliased Type

struct PbStreamActor {
    pub actor_id: u32,
    pub fragment_id: u32,
    pub nodes: Option<StreamNode>,
    pub dispatcher: Vec<Dispatcher>,
    pub upstream_actor_id: Vec<u32>,
    pub vnode_bitmap: Option<Buffer>,
    pub mview_definition: String,
    pub expr_context: Option<ExprContext>,
}

Fields

actor_id: u32

fragment_id: u32

nodes: Option<StreamNode>

dispatcher: Vec<Dispatcher>

upstream_actor_id: Vec<u32>

The actors that send messages to this actor. Note that upstream actor ids are also stored in the proto of merge nodes. It is painstaking to traverse through the node tree and get upstream actor id from the root StreamNode. We duplicate the information here to ease the parsing logic in stream manager.

vnode_bitmap: Option<Buffer>

Vnodes that the executors in this actor own. If the fragment is a singleton, this field will not be set and leave a None.

mview_definition: String

The SQL definition of this materialized view. Used for debugging only.

expr_context: Option<ExprContext>

Provide the necessary context, e.g. session info like time zone, for the actor.