risingwave_pb::stream_plan

Type Alias PbUpdateMutation

source
pub type PbUpdateMutation = UpdateMutation;
Expand description

Alias for UpdateMutation.

Aliased Type§

struct PbUpdateMutation {
    pub dispatcher_update: Vec<DispatcherUpdate>,
    pub merge_update: Vec<MergeUpdate>,
    pub actor_vnode_bitmap_update: HashMap<u32, Buffer>,
    pub dropped_actors: Vec<u32>,
    pub actor_splits: HashMap<u32, ConnectorSplits>,
    pub actor_new_dispatchers: HashMap<u32, Dispatchers>,
}

Fields§

§dispatcher_update: Vec<DispatcherUpdate>

Dispatcher updates.

§merge_update: Vec<MergeUpdate>

Merge updates.

§actor_vnode_bitmap_update: HashMap<u32, Buffer>

Vnode bitmap updates for each actor.

§dropped_actors: Vec<u32>

All actors to be dropped in this update.

§actor_splits: HashMap<u32, ConnectorSplits>

Source updates. Source and SourceBackfill are handled together here.

§actor_new_dispatchers: HashMap<u32, Dispatchers>

When modifying the Materialized View, we need to recreate the Dispatcher from the old upstream to the new TableFragment. Consistent with the semantics in AddMutation.