PbFragmentDistribution

Type Alias PbFragmentDistribution 

Source
pub type PbFragmentDistribution = FragmentDistribution;

Aliased Type§

pub struct PbFragmentDistribution {
    pub fragment_id: TypedId<4, u32>,
    pub table_id: TypedId<1, u32>,
    pub distribution_type: i32,
    pub state_table_ids: Vec<TypedId<0, u32>>,
    pub upstream_fragment_ids: Vec<TypedId<4, u32>>,
    pub fragment_type_mask: u32,
    pub parallelism: u32,
    pub vnode_count: u32,
    pub node: Option<StreamNode>,
    pub parallelism_policy: String,
}

Fields§

§fragment_id: TypedId<4, u32>§table_id: TypedId<1, u32>§distribution_type: i32§state_table_ids: Vec<TypedId<0, u32>>§upstream_fragment_ids: Vec<TypedId<4, u32>>§fragment_type_mask: u32§parallelism: u32§vnode_count: u32§node: Option<StreamNode>§parallelism_policy: String