Struct ActorBuilder

struct ActorBuilder {
    actor_id: GlobalId<{ IdCategory::Actor }>,
    fragment_id: GlobalId<{ IdCategory::Fragment }>,
    nodes: Arc<StreamNode>,
    downstreams: HashMap<DispatcherId, Dispatcher>,
    upstreams: HashMap<EdgeId, ActorUpstream>,
    vnode_bitmap: Option<Bitmap>,
}

ActorBuilder builds a stream actor in a stream DAG.

Fields

actor_id: GlobalId<{ IdCategory::Actor }>

The ID of this actor.

fragment_id: GlobalId<{ IdCategory::Fragment }>

The fragment ID of this actor.

nodes: Arc<StreamNode>

The body of this actor, verbatim from the frontend.

This cannot be directly used for execution, and it will be rewritten after we know all of the upstreams and downstreams in the end. See rewrite.

downstreams: HashMap<DispatcherId, Dispatcher>

The dispatchers to the downstream actors.

upstreams: HashMap<EdgeId, ActorUpstream>

The upstream actors.

vnode_bitmap: Option<Bitmap>

The virtual node bitmap, if this fragment is hash distributed.

Implementations

impl ActorBuilder

fn new( actor_id: GlobalId<{ IdCategory::Actor }>, fragment_id: GlobalId<{ IdCategory::Fragment }>, vnode_bitmap: Option<Bitmap>, node: Arc<StreamNode>, ) -> Self

fn fragment_id(&self) -> GlobalId<{ IdCategory::Fragment }>

fn add_dispatcher(&mut self, dispatcher: Dispatcher)

Add a dispatcher to this actor.

fn add_upstream(&mut self, upstream: ActorUpstream)

Add an upstream to this actor.

fn rewrite(&self) -> MetaResult<StreamNode>

Rewrite the actor body.

During this process, the following things will be done:

1. Replace the logical Exchange in node’s input with Merge, which can be executed on the compute nodes.
2. Fill the upstream mview info of the Merge node under the other “leaf” nodes.

fn rewrite_inner( &self, stream_node: &StreamNode, depth: usize, ) -> MetaResult<StreamNode>

fn build( self, job: &StreamingJob, expr_context: ExprContext, ) -> MetaResult<StreamActor>

Build an actor after all the upstreams and downstreams are processed.

Trait Implementations

impl Debug for ActorBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.