Enum DataFrameError 

pub enum DataFrameError {
    Io {
        source: Error,
        path: Option<PathBuf>,
    },
    SchemaMismatch {
        message: String,
    },
    TypeMismatch {
        column: Option<String>,
        expected: String,
        actual: String,
    },
    ColumnNotFound {
        name: String,
    },
    InvalidOperation {
        message: String,
    },
    Configuration {
        option: String,
        message: String,
    },
    Arrow {
        source: ArrowError,
    },
    Parquet {
        source: ParquetError,
    },
    ResourceLimitExceeded {
        limit: u64,
        observed: u64,
        max_in_flight_batches: usize,
        observed_batches: usize,
        scope: ResourceScope,
    },
    StreamClosed,
    StreamCancelled,
    StreamFailed {
        code: &'static str,
        classification: StreamFailureClass,
    },
    StreamingUnsupported {
        subject: String,
        reason: String,
    },
    StreamingRequiresMaterialization {
        subject: String,
        reason: String,
    },
}

Re-export of the crate error type and result alias. Errors returned by alopex-dataframe operations.

Variants

Io

OS-level I/O error (optionally associated with a path).

Fields

source: Error

path: Option<PathBuf>

SchemaMismatch

Arrow schema-related mismatch (e.g. different schema across batches).

Fields

message: String

TypeMismatch

Data type mismatch (e.g. non-numeric aggregation or incompatible dtypes).

Fields

column: Option<String>

expected: String

actual: String

ColumnNotFound

Referenced column does not exist.

Fields

name: String

InvalidOperation

Operation is not supported or invalid for the current inputs.

Fields

message: String

Configuration

Invalid configuration option was provided.

Fields

option: String

message: String

Arrow

Error originating from Arrow compute / record batch APIs.

Fields

source: ArrowError

Parquet

Error originating from Parquet APIs.

Fields

source: ParquetError

ResourceLimitExceeded

A bounded execution reservation was rejected before the requested ownership began.

Fields

limit: u64

Configured byte limit.

observed: u64

Requested byte total at the failed reservation point.

max_in_flight_batches: usize

Configured in-flight batch limit.

observed_batches: usize

Requested in-flight batch total at the failed reservation point.

scope: ResourceScope

Allocation domain that requested the reservation.

StreamClosed

A stream was closed by its consumer before normal completion.

StreamCancelled

A stream was cancelled by its consumer before normal completion.

StreamFailed

A stream failed and must reproduce its initial structured diagnostic.

Fields

code: &'static str

Stable failure code.

classification: StreamFailureClass

Stable broad failure classification.

StreamingUnsupported

Streaming was rejected before the source was opened.

Fields

subject: String

reason: String

StreamingRequiresMaterialization

Streaming would require global materialization and has no approved bounded algorithm.

Fields

subject: String

reason: String

Implementations

impl DataFrameError

pub fn io(source: Error) -> Self

Create an I/O error without a path.

pub fn io_with_path(source: Error, path: impl Into<PathBuf>) -> Self

Create an I/O error associated with a path.

pub fn schema_mismatch(message: impl Into<String>) -> Self

Create a schema mismatch error with a message.

pub fn type_mismatch( column: impl Into<Option<String>>, expected: impl Into<String>, actual: impl Into<String>, ) -> Self

Create a type mismatch error with optional column context.

pub fn column_not_found(name: impl Into<String>) -> Self

Create a missing column error.

pub fn invalid_operation(message: impl Into<String>) -> Self

Create an invalid operation error.

pub fn configuration( option: impl Into<String>, message: impl Into<String>, ) -> Self

Create an invalid configuration error.

pub fn resource_limit_exceeded( limit: u64, observed: u64, max_in_flight_batches: usize, observed_batches: usize, scope: ResourceScope, ) -> Self

Create a structured resource-limit error.

pub const fn stream_closed() -> Self

Create the repeatable early-close terminal error.

pub const fn stream_cancelled() -> Self

Create the repeatable cancellation terminal error.

pub const fn stream_failed( code: &'static str, classification: StreamFailureClass, ) -> Self

Create the repeatable structured stream-failure error.

pub fn streaming_unsupported( subject: impl Into<String>, reason: impl Into<String>, ) -> Self

Create a source-open preflight rejection without falling back to eager execution.

pub fn streaming_requires_materialization( subject: impl Into<String>, reason: impl Into<String>, ) -> Self

Create a preflight rejection for a plan requiring unimplemented global materialization.

Trait Implementations

impl Debug for DataFrameError

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

Formats the value using the given formatter.

impl Display for DataFrameError

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

Formats the value using the given formatter.

impl Error for DataFrameError

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.