Type Alias PbFragment

pub type PbFragment = Fragment;

Alias for Fragment.

Aliased Type

struct PbFragment {
    pub fragment_id: u32,
    pub fragment_type_mask: u32,
    pub distribution_type: i32,
    pub actors: Vec<StreamActor>,
    pub state_table_ids: Vec<u32>,
    pub upstream_fragment_ids: Vec<u32>,
    pub maybe_vnode_count: Option<u32>,
}

Fields

fragment_id: u32

fragment_type_mask: u32

Bitwise-OR of FragmentTypeFlags

distribution_type: i32

actors: Vec<StreamActor>

state_table_ids: Vec<u32>

upstream_fragment_ids: Vec<u32>

Note that this can be derived backwards from the upstream actors of the Actor held by the Fragment, but in some scenarios (e.g. Scaling) it will lead to a lot of duplicate code, so we pre-generate and store it here, this member will only be initialized when creating the Fragment and modified when creating the mv-on-mv

maybe_vnode_count: Option<u32>

Total vnode count of the fragment (then all internal tables). Duplicated from the length of the vnode bitmap in any actor of the fragment.

Can be unset if the fragment is created in older versions where variable vnode count is not supported, in which case a default value of 256 (or 1 for singleton) should be used. Use VnodeCountCompat::vnode_count to access it.