Struct Fragment

pub struct Fragment {
    pub fragment_id: FragmentId,
    pub fragment_type_mask: u32,
    pub distribution_type: PbFragmentDistributionType,
    pub actors: Vec<StreamActor>,
    pub state_table_ids: Vec<u32>,
    pub maybe_vnode_count: Option<u32>,
    pub nodes: StreamNode,
}

Fields

fragment_id: FragmentId

fragment_type_mask: u32

distribution_type: PbFragmentDistributionType

actors: Vec<StreamActor>

state_table_ids: Vec<u32>

maybe_vnode_count: Option<u32>

nodes: StreamNode

Implementations

impl Fragment

pub fn to_protobuf( &self, upstream_fragments: impl Iterator<Item = FragmentId>, dispatchers: Option<&HashMap<ActorId, Vec<Dispatcher>>>, ) -> PbFragment

Trait Implementations

impl Clone for Fragment

fn clone(&self) -> Fragment

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Fragment

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Fragment

fn default() -> Fragment

Returns the “default value” for a type.

impl IsSingleton for Fragment

fn is_singleton(&self) -> bool

Returns true if the table/fragment is a singleton.

impl VnodeCountCompat for Fragment

fn vnode_count_inner(&self) -> VnodeCount

Get the maybe_vnode_count field.

fn vnode_count(&self) -> usize

Returns the vnode count if it’s set. Otherwise, returns [VirtualNode::COUNT_FOR_COMPAT] for distributed tables/fragments, and 1 for singleton tables/fragments, for backward compatibility. Panics if the field is a placeholder.