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<TypedId<6>, Buffer>,
pub dropped_actors: Vec<TypedId<6>>,
pub actor_splits: HashMap<TypedId<6>, ConnectorSplits>,
pub actor_new_dispatchers: HashMap<TypedId<6>, Dispatchers>,
pub actor_cdc_table_snapshot_splits: Option<CdcTableSnapshotSplitsWithGeneration>,
pub sink_add_columns: HashMap<TypedId<8>, SinkAddColumns>,
}Fields§
§dispatcher_update: Vec<DispatcherUpdate>Dispatcher updates.
merge_update: Vec<MergeUpdate>Merge updates.
actor_vnode_bitmap_update: HashMap<TypedId<6>, Buffer>Vnode bitmap updates for each actor.
dropped_actors: Vec<TypedId<6>>All actors to be dropped in this update.
actor_splits: HashMap<TypedId<6>, ConnectorSplits>Source updates.
Source and SourceBackfill are handled together here.
actor_new_dispatchers: HashMap<TypedId<6>, 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<TypedId<8>, SinkAddColumns>