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.
• ActorUpstream 🔒
  The upstream information of an actor during the building process. This will eventually be used to create the MergeNodes as the leaf executor of each actor.
• ExternalChange 🔒
  The required changes to an existing external actor to build the graph of a streaming job.
• FragmentLinkNode 🔒
  The information of a fragment, used for parameter passing for Inner::add_link.

Type Aliases

• ActorLocations 🔒
  The worker slot location of actors.