Enum Route 

pub enum Route {
    Forward(u32),
    Shuffle {
        columns: Vec<String>,
        vnodes: u32,
        targets: Vec<(u32, Range<u32>)>,
        hasher: Arc<dyn Fn(&[Arc<dyn Array>], &mut [u64]) + Send + Sync>,
    },
    Broadcast(Vec<u32>),
}

Where a task’s output goes.

Variants

Forward(u32)

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<(u32, Range<u32>)>

hasher: Arc<dyn Fn(&[Arc<dyn Array>], &mut [u64]) + Send + Sync>

Broadcast(Vec<u32>)

The same batch to every target.

Implementations

impl Route

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

Trait Implementations

impl Clone for Route

fn clone(&self) -> Route

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<(), Error>

Formats the value using the given formatter.