Enum DistributedError 

#[non_exhaustive]
pub enum DistributedError {
    UnknownTable(String),
    EmptyLayout {
        table: String,
    },
    InvalidPlan(String),
    Reservation {
        fragment_id: u32,
        reason: String,
    },
    FragmentExecution {
        fragment_id: u32,
        worker: String,
        message: String,
    },
    Cancelled(CancellationReason),
    Unsupported(String),
    Arrow(String),
}

Errors raised by distributed planning and coordination.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

UnknownTable(String)

The locator or metadata has no entry for the table.

EmptyLayout

The table’s layout has no tablets to scan.

Fields

table: String

InvalidPlan(String)

The input IR or a computed plan is not well-formed.

Reservation

A fragment’s resource reservation was denied.

Fields

fragment_id: u32

reason: String

FragmentExecution

A fragment failed on its worker.

Fields

fragment_id: u32

worker: String

message: String

Cancelled(CancellationReason)

The query was cancelled; carries the first observed reason.

Unsupported(String)

A groundwork boundary was crossed (documented later-wave work).

Arrow(String)

Arrow kernel failure inside a merge operator.

Trait Implementations

impl Debug for DistributedError

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

Formats the value using the given formatter.

impl Display for DistributedError

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

Formats the value using the given formatter.

impl Error for DistributedError

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 DistributedError

fn from(error: ArrowError) -> Self

Converts to this type from the input type.