Enum OutputDistribution 

pub enum OutputDistribution {
    VnodePartitioned {
        key_expressions_fingerprint: SubscriptionDigest,
        partition_abi: u16,
        vnode_count: u16,
    },
    Singleton {
        partition: OutputPartitionId,
    },
}

Recoverable mapping from final operator output to subscription partitions.

Variants

VnodePartitioned

Group keys use the stable partition ABI and produce output on the same vnode.

Fields

key_expressions_fingerprint: SubscriptionDigest

Digest of canonical grouping-key expressions and types.

partition_abi: u16

Exact key encoding and vnode mapping ABI.

vnode_count: u16

Complete logical vnode domain.

Singleton

Existing global-aggregate execution on the singleton vnode.

Fields

partition: OutputPartitionId

Singleton/global vnode.

Implementations

impl OutputDistribution

pub const fn partition_count(&self) -> u16

Number of certified output partitions.

pub fn contains(&self, partition: OutputPartitionId) -> bool

Whether partition belongs to this certified output domain.

Trait Implementations

impl Clone for OutputDistribution

fn clone(&self) -> OutputDistribution

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutputDistribution

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OutputDistribution

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for OutputDistribution

impl PartialEq for OutputDistribution

fn eq(&self, other: &OutputDistribution) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl Serialize for OutputDistribution

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for OutputDistribution