risingwave_pb::stream_plan

Type Alias PbAddMutation

source
pub type PbAddMutation = AddMutation;
Expand description

Alias for AddMutation.

Aliased Type§

struct PbAddMutation {
    pub actor_dispatchers: HashMap<u32, Dispatchers>,
    pub added_actors: Vec<u32>,
    pub actor_splits: HashMap<u32, ConnectorSplits>,
    pub pause: bool,
    pub subscriptions_to_add: Vec<SubscriptionUpstreamInfo>,
}

Fields§

§actor_dispatchers: HashMap<u32, Dispatchers>

New dispatchers for each actor.

§added_actors: Vec<u32>

All actors to be added (to the main connected component of the graph) in this update.

§actor_splits: HashMap<u32, ConnectorSplits>

We may embed a source change split mutation here. Source and SourceBackfill are handled together here. TODO: we may allow multiple mutations in a single barrier.

§pause: bool

We may embed a pause mutation here. TODO: we may allow multiple mutations in a single barrier.

§subscriptions_to_add: Vec<SubscriptionUpstreamInfo>