Enum DistributedError 

pub enum DistributedError {
    FlightRpc(String),
    WorkerConnection(String),
    WorkerTaskFailure(String),
    Coordinator(String),
    Partitioning(String),
    Shuffle(String),
    TaskSerialization(String),
    Timeout(String),
    Authentication(String),
    ResourceAllocation(String),
    Aggregation(String),
    Arrow(String),
    Core(OxiGdalError),
    Io(Error),
    Json(Error),
    Transport(Error),
    Status(Status),
    Custom(String),
}

Errors that can occur during distributed processing.

Variants

FlightRpc(String)

Error during Flight RPC communication.

WorkerConnection(String)

Error connecting to a worker node.

WorkerTaskFailure(String)

Worker failed to complete a task.

Coordinator(String)

Coordinator error.

Partitioning(String)

Data partitioning error.

Shuffle(String)

Data shuffle error.

TaskSerialization(String)

Task serialization/deserialization error.

Timeout(String)

Network timeout error.

Authentication(String)

Authentication error.

ResourceAllocation(String)

Resource allocation error.

Aggregation(String)

Result aggregation error.

Arrow(String)

Arrow error during data transfer.

Core(OxiGdalError)

Core OxiGDAL error.

Io(Error)

I/O error.

Json(Error)

JSON serialization error.

Transport(Error)

Tonic transport error.

Status(Status)

Tonic status error.

Custom(String)

Generic error with custom message.

Implementations

impl DistributedError

pub fn flight_rpc<S: Into<String>>(msg: S) -> Self

Create a Flight RPC error.

pub fn worker_connection<S: Into<String>>(msg: S) -> Self

Create a worker connection error.

pub fn worker_task_failure<S: Into<String>>(msg: S) -> Self

Create a worker task failure error.

pub fn coordinator<S: Into<String>>(msg: S) -> Self

Create a coordinator error.

pub fn partitioning<S: Into<String>>(msg: S) -> Self

Create a partitioning error.

pub fn shuffle<S: Into<String>>(msg: S) -> Self

Create a shuffle error.

pub fn task_serialization<S: Into<String>>(msg: S) -> Self

Create a task serialization error.

pub fn timeout<S: Into<String>>(msg: S) -> Self

Create a timeout error.

pub fn authentication<S: Into<String>>(msg: S) -> Self

Create an authentication error.

pub fn resource_allocation<S: Into<String>>(msg: S) -> Self

Create a resource allocation error.

pub fn aggregation<S: Into<String>>(msg: S) -> Self

Create an aggregation error.

pub fn arrow<S: Into<String>>(msg: S) -> Self

Create an Arrow error.

pub fn custom<S: Into<String>>(msg: S) -> Self

Create a custom error.

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(err: ArrowError) -> Self

Converts to this type from the input type.

impl From<DistributedError> for Status

fn from(err: DistributedError) -> Self

Converts to this type from the input type.

impl From<Error> for DistributedError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for DistributedError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for DistributedError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<OxiGdalError> for DistributedError

fn from(source: OxiGdalError) -> Self

Converts to this type from the input type.

impl From<Status> for DistributedError

fn from(source: Status) -> Self

Converts to this type from the input type.