Struct ActorGraphBuildStateInner

struct ActorGraphBuildStateInner {
    actor_builders: BTreeMap<GlobalId<{ IdCategory::Actor }>, ActorBuilder>,
    building_locations: BTreeMap<GlobalId<{ IdCategory::Actor }>, WorkerSlotId>,
    external_changes: BTreeMap<GlobalId<{ IdCategory::Actor }>, ExternalChange>,
    external_locations: BTreeMap<GlobalId<{ IdCategory::Actor }>, WorkerSlotId>,
}

The actual mutable state of building an actor graph.

When the fragments are visited in a topological order, actor builders will be added to this state and the scheduled locations will be added. As the building process is run on the complete graph which also contains the info of the existing (external) fragments, the info of them will be also recorded.

Fields

actor_builders: BTreeMap<GlobalId<{ IdCategory::Actor }>, ActorBuilder>

The builders of the actors to be built.

building_locations: BTreeMap<GlobalId<{ IdCategory::Actor }>, WorkerSlotId>

The scheduled locations of the actors to be built.

external_changes: BTreeMap<GlobalId<{ IdCategory::Actor }>, ExternalChange>

The required changes to the external actors. See ExternalChange.

external_locations: BTreeMap<GlobalId<{ IdCategory::Actor }>, WorkerSlotId>

The actual locations of the external actors.

Implementations

impl ActorGraphBuildStateInner

fn add_actor( &mut self, actor_id: GlobalId<{ IdCategory::Actor }>, fragment_id: GlobalId<{ IdCategory::Fragment }>, worker_slot_id: WorkerSlotId, vnode_bitmap: Option<Bitmap>, node: Arc<StreamNode>, )

Insert new generated actor and record its location.

The vnode_bitmap should be Some for the actors of hash-distributed fragments.

fn record_external_location( &mut self, actor_id: GlobalId<{ IdCategory::Actor }>, worker_slot_id: WorkerSlotId, )

Record the location of an external actor.

fn new_hash_dispatcher( strategy: &DispatchStrategy, downstream_fragment_id: GlobalId<{ IdCategory::Fragment }>, downstream_actors: &[GlobalId<{ IdCategory::Actor }>], downstream_actor_mapping: ActorMapping, ) -> Dispatcher

Create a new hash dispatcher.

fn new_normal_dispatcher( strategy: &DispatchStrategy, downstream_fragment_id: GlobalId<{ IdCategory::Fragment }>, downstream_actors: &[GlobalId<{ IdCategory::Actor }>], ) -> Dispatcher

Create a new dispatcher for non-hash types.

fn add_dispatcher( &mut self, actor_id: GlobalId<{ IdCategory::Actor }>, dispatcher: Dispatcher, )

Add the new dispatcher for an actor.

• If the actor is to be built, the dispatcher will be added to the actor builder.
• If the actor is an external actor, the dispatcher will be added to the external changes.

fn add_upstream( &mut self, actor_id: GlobalId<{ IdCategory::Actor }>, upstream: ActorUpstream, )

Add the new upstream for an actor.

• If the actor is to be built, the upstream will be added to the actor builder.
• If the actor is an external actor, the upstream will be added to the external changes.

fn get_location( &self, actor_id: GlobalId<{ IdCategory::Actor }>, ) -> WorkerSlotId

Get the location of an actor. Will look up the location map of both the actors to be built and the external actors.

fn add_link<'a>( &mut self, upstream: FragmentLinkNode<'a>, downstream: FragmentLinkNode<'a>, edge: &'a StreamFragmentEdge, )

Add a “link” between two fragments in the graph.

The edge will be expanded into multiple (downstream - upstream) pairs for the actors in the two fragments, based on the distribution and the dispatch strategy. They will be finally transformed to Dispatcher and Merge nodes when building the actors.

If there’re existing (external) fragments, the info will be recorded in external_changes, instead of the actor builders.

Trait Implementations

impl Default for ActorGraphBuildStateInner

fn default() -> ActorGraphBuildStateInner

Returns the “default value” for a type.