Enum ExchangeKind 

pub enum ExchangeKind {
    HashRepartition {
        keys: Vec<String>,
    },
    Broadcast,
    Merge,
}

How rows move across one exchange edge (spec section 12.10).

Variants

HashRepartition

Rows are hash-routed on keys across the sibling consumers of the producing fragment.

Fields

keys: Vec<String>

Hash key columns (in the producer’s output schema).

Broadcast

The producer’s full output is replicated to every consumer.

Merge

The producer’s output flows to its single consumer.

Trait Implementations

impl Clone for ExchangeKind

fn clone(&self) -> ExchangeKind

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ExchangeKind

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ExchangeKind

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for ExchangeKind

impl PartialEq for ExchangeKind

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for ExchangeKind

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 ExchangeKind