pub type PbUpdateMutation = UpdateMutation;Aliased Type§
pub 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>,
pub actor_cdc_table_snapshot_splits: Option<CdcTableSnapshotSplitsWithGeneration>,
pub sink_add_columns: HashMap<u32, SinkAddColumns>,
}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.
actor_cdc_table_snapshot_splits: Option<CdcTableSnapshotSplitsWithGeneration>CDC table snapshot splits
sink_add_columns: HashMap<u32, SinkAddColumns>