Enum Route 

pub enum Route {
    Forward(TaskId),
    Shuffle {
        columns: Vec<String>,
        vnodes: u32,
        targets: Vec<(TaskId, Range<u32>)>,
        hasher: Hasher,
    },
    Broadcast(Vec<TaskId>),
}

Where a task’s output goes.

Variants

Forward(TaskId)

Whole batches to one task.

Shuffle

Rows hashed on columns into vnodes; each target owns a contiguous vnode range.

Fields

columns: Vec<String>

vnodes: u32

targets: Vec<(TaskId, Range<u32>)>

hasher: Hasher

Broadcast(Vec<TaskId>)

The same batch to every target.

Implementations

impl Route

pub fn targets(&self) -> Vec<TaskId>

Trait Implementations

impl Clone for Route

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Route

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

Formats the value using the given formatter.