Module actor

Structs§

ActorBuilder 🔒: ActorBuilder builds a stream actor in a stream DAG.
ActorGraphBuildResult: The result of a built actor graph. Will be further embedded into the Context for building actors on the compute nodes.
ActorGraphBuildState 🔒: The mutable state of building an actor graph. See ActorGraphBuildStateInner.
ActorGraphBuildStateInner 🔒: The actual mutable state of building an actor graph.
ActorGraphBuilder: ActorGraphBuilder builds the actor graph for the given complete fragment graph, based on the current cluster info and the required parallelism.
DownstreamFragmentChange 🔒
FragmentActorBuilder 🔒
FragmentLinkNode 🔒: The information of a fragment, used for parameter passing for Inner::add_link.
UpstreamFragmentChange 🔒: The required changes to an existing external actor to build the graph of a streaming job.