Struct ShufflePeerFlow 

pub struct ShufflePeerFlow {
    pub peer: ShufflePeerId,
    pub send_wait: Duration,
    pub sent_bytes: u64,
    pub sent_rows: u64,
}

Totals of one peer’s outbound shuffle stream since its sender was created. They survive reconnects to the peer.

Fields

peer: ShufflePeerId

The peer’s node id.

send_wait: Duration

Time sends waited for the peer’s or the node’s outbound byte budget, or for a slot in the peer’s stream queue. Sends to one peer take turns and the turn is not counted, so this tracks how long the peer’s stream was blocked. A send cancelled while waiting still counts.

sent_bytes: u64

Arrow IPC payload bytes of data frames queued to the peer’s stream; control frames are excluded.

sent_rows: u64

Rows of those data frames.

Trait Implementations

impl Clone for ShufflePeerFlow

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ShufflePeerFlow

impl Debug for ShufflePeerFlow

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

Formats the value using the given formatter.

impl Default for ShufflePeerFlow

fn default() -> Self

Returns the “default value” for a type.

impl Eq for ShufflePeerFlow

impl PartialEq for ShufflePeerFlow

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for ShufflePeerFlow