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