Enum ShuffleMessage 

pub enum ShuffleMessage {
    Barrier(CheckpointBarrier),
    Hello(u64),
    VnodeData(u32, RecordBatch),
    Close(String),
}

Logical message carried on a shuffle connection.

Variants

Barrier(CheckpointBarrier)

A checkpoint barrier (Chandy-Lamport).

Hello(u64)

Peer identifying itself during the connection handshake.

VnodeData(u32, RecordBatch)

A batch of rows pre-routed to vnode.

Close(String)

Sender announcing graceful shutdown with a brief reason.

Trait Implementations

impl Clone for ShuffleMessage

fn clone(&self) -> ShuffleMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ShuffleMessage

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

Formats the value using the given formatter.

impl PartialEq for ShuffleMessage

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for ShuffleMessage