Enum ShuffleRoutingError 

pub enum ShuffleRoutingError {
    EmptyKey,
    EmptyVnodeSpace,
    KeyColumnOutOfRange {
        index: usize,
        columns: usize,
    },
    UnsupportedKeyType {
        index: usize,
        data_type: DataType,
    },
    Arrow(ArrowError),
    RowVnodeCardinality {
        rows: usize,
        vnodes: usize,
    },
    TooManyRows {
        rows: usize,
    },
    VnodeOutOfRange {
        vnode: u32,
        vnode_count: usize,
    },
    UnassignedVnode {
        vnode: u32,
    },
    OversizedRow {
        vnode: u32,
        bytes: usize,
        limit: usize,
    },
}

A routing failure. No plan is returned, so callers cannot partially send or silently drop rows.

Variants

EmptyKey

Keyed routing requires at least one key column.

EmptyVnodeSpace

Modulo routing is undefined for an empty vnode space.

KeyColumnOutOfRange

A resolved key index no longer exists in the batch schema.

Fields

index: usize

Requested zero-based index.

columns: usize

Available columns.

UnsupportedKeyType

ABI v1 admits only scalar, non-floating key types.

Fields

index: usize

Requested zero-based index.

data_type: DataType

Rejected Arrow type.

Arrow(ArrowError)

Arrow row encoding or slicing failed.

RowVnodeCardinality

Routing metadata must cover every input row exactly once.

Fields

rows: usize

Input row count.

vnodes: usize

Supplied route count.

TooManyRows

UInt32 take indices cannot represent this input cardinality.

Fields

rows: usize

Input row count.

VnodeOutOfRange

The route references a vnode outside the pinned assignment.

Fields

vnode: u32

Invalid vnode.

vnode_count: usize

Pinned assignment cardinality.

UnassignedVnode

Formation/rebalance has not assigned this vnode yet.

Fields

vnode: u32

Vnode awaiting an owner.

OversizedRow

A single row cannot be split further and would always fail receiver admission.

Fields

vnode: u32

Row’s routed vnode.

bytes: usize

Decoded Arrow bytes.

limit: usize

Hard decoded limit.

Implementations

impl ShuffleRoutingError

pub const fn is_not_ready(&self) -> bool

Whether retrying after assignment convergence can succeed without changing the input.

Trait Implementations

impl Debug for ShuffleRoutingError

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

Formats the value using the given formatter.

impl Display for ShuffleRoutingError

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

Formats the value using the given formatter.

impl Error for ShuffleRoutingError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0:

use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0:

replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl From<ArrowError> for ShuffleRoutingError

fn from(source: ArrowError) -> Self

Converts to this type from the input type.