Enum Distribution

pub(super) enum Distribution {
    Singleton(WorkerSlotId),
    Hash(WorkerSlotMapping),
}

The distribution (scheduling result) of a fragment.

Variants

Singleton(WorkerSlotId)

The fragment is singleton and is scheduled to the given worker slot.

Hash(WorkerSlotMapping)

The fragment is hash-distributed and is scheduled by the given hash mapping.

Implementations

impl Distribution

pub fn is_singleton(&self) -> bool

Returns true if this is a Distribution::Singleton, otherwise false

pub fn as_singleton_mut(&mut self) -> Option<&mut WorkerSlotId>

Optionally returns mutable references to the inner fields if this is a Distribution::Singleton, otherwise None

pub fn as_singleton(&self) -> Option<&WorkerSlotId>

Optionally returns references to the inner fields if this is a Distribution::Singleton, otherwise None

pub fn into_singleton(self) -> Result<WorkerSlotId, Self>

Returns the inner fields if this is a Distribution::Singleton, otherwise returns back the enum in the Err case of the result

pub fn is_hash(&self) -> bool

Returns true if this is a Distribution::Hash, otherwise false

pub fn as_hash_mut(&mut self) -> Option<&mut WorkerSlotMapping>

Optionally returns mutable references to the inner fields if this is a Distribution::Hash, otherwise None

pub fn as_hash(&self) -> Option<&WorkerSlotMapping>

Optionally returns references to the inner fields if this is a Distribution::Hash, otherwise None

pub fn into_hash(self) -> Result<WorkerSlotMapping, Self>

Returns the inner fields if this is a Distribution::Hash, otherwise returns back the enum in the Err case of the result

impl Distribution

pub fn parallelism(&self) -> usize

The parallelism required by the distribution.

pub fn worker_slots(&self) -> impl Iterator<Item = WorkerSlotId> + '_

All worker slots required by the distribution.

pub fn vnode_count(&self) -> usize

Get the vnode count of the distribution.

pub fn from_fragment( fragment: &Fragment, actor_location: &HashMap<ActorId, WorkerId>, ) -> Self

Create a distribution from a persisted protobuf Fragment.

pub fn to_distribution_type(&self) -> PbFragmentDistributionType

Convert the distribution to PbFragmentDistributionType.

Trait Implementations

impl Clone for Distribution

fn clone(&self) -> Distribution

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Distribution

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

Formats the value using the given formatter.