Struct ActorGraphBuildStateInner 

struct ActorGraphBuildStateInner {
    fragment_actor_builders: BTreeMap<GlobalId<{ IdCategory::Fragment }>, FragmentActorBuilder>,
    building_locations: BTreeMap<GlobalActorId, ActorAlignmentId>,
    downstream_fragment_changes: BTreeMap<GlobalId<{ IdCategory::Fragment }>, DownstreamFragmentChange>,
    upstream_fragment_changes: BTreeMap<GlobalId<{ IdCategory::Fragment }>, UpstreamFragmentChange>,
    external_locations: BTreeMap<GlobalActorId, ActorAlignmentId>,
}

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

fragment_actor_builders: BTreeMap<GlobalId<{ IdCategory::Fragment }>, FragmentActorBuilder>

The builders of the actors to be built.

building_locations: BTreeMap<GlobalActorId, ActorAlignmentId>

The scheduled locations of the actors to be built.

downstream_fragment_changes: BTreeMap<GlobalId<{ IdCategory::Fragment }>, DownstreamFragmentChange>

The required changes to the external downstream fragment. See DownstreamFragmentChange. Indexed by the fragment_id of fragments that have updates on its downstream.

upstream_fragment_changes: BTreeMap<GlobalId<{ IdCategory::Fragment }>, UpstreamFragmentChange>

The required changes to the external upstream fragment. See UpstreamFragmentChange. /// Indexed by the fragment_id of fragments that have updates on its upstream.

external_locations: BTreeMap<GlobalActorId, ActorAlignmentId>

The actual locations of the external actors.

Implementations

impl ActorGraphBuildStateInner

fn add_actor( &mut self, (fragment_id, actor_id): (GlobalId<{ IdCategory::Fragment }>, GlobalActorId), actor_alignment_id: ActorAlignmentId, vnode_bitmap: Option<Bitmap>, )

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: GlobalActorId, actor_alignment_id: ActorAlignmentId, )

Record the location of an external actor.

fn add_dispatcher( &mut self, fragment_id: GlobalId<{ IdCategory::Fragment }>, downstream_fragment_id: GlobalId<{ IdCategory::Fragment }>, dispatch: DispatchStrategy, )

Add the new downstream fragment relation to a fragment.

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

fn add_upstream( &mut self, fragment_id: GlobalId<{ IdCategory::Fragment }>, edge_id: EdgeId, upstream_fragment_id: GlobalId<{ IdCategory::Fragment }>, no_shuffle_actor_mapping: Option<HashMap<GlobalActorId, GlobalActorId>>, )

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: GlobalActorId) -> ActorAlignmentId

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 transformed into the fragment relation (downstream - upstream) pair between 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 upstream_fragment_changes and downstream_fragment_changes, instead of the actor builders.

Trait Implementations

impl Default for ActorGraphBuildStateInner

fn default() -> ActorGraphBuildStateInner

Returns the “default value” for a type.