Enum DeltaTableError

pub enum DeltaTableError {
    KernelError(Error),
    Protocol {
        source: ProtocolError,
    },
    ObjectStore {
        source: Error,
    },
    Parquet {
        source: ParquetError,
    },
    Arrow {
        source: ArrowError,
    },
    InvalidJsonLog {
        json_err: Error,
        line: String,
        version: i64,
    },
    InvalidStatsJson {
        json_err: Error,
    },
    InvalidInvariantJson {
        json_err: Error,
        line: String,
    },
    InvalidVersion(i64),
    MissingDataFile {
        source: Error,
        path: String,
    },
    InvalidDateTimeString {
        source: ParseError,
    },
    InvalidData {
        violations: Vec<String>,
    },
    NotATable(String),
    NoMetadata,
    NoSchema,
    LoadPartitions,
    SchemaMismatch {
        msg: String,
    },
    PartitionError {
        partition: String,
    },
    InvalidPartitionFilter {
        partition_filter: String,
    },
    ColumnsNotPartitioned {
        nonpartitioned_columns: Vec<String>,
    },
    Io {
        source: Error,
    },
    CommitValidation {
        source: CommitBuilderError,
    },
    Transaction {
        source: TransactionError,
    },
    VersionAlreadyExists(i64),
    VersionMismatch(i64, i64),
    MissingFeature {
        feature: &'static str,
        url: String,
    },
    InvalidTableLocation(String),
    SerializeLogJson {
        json_err: Error,
    },
    SerializeSchemaJson {
        json_err: Error,
    },
    Generic(String),
    GenericError {
        source: Box<dyn Error + Send + Sync + 'static>,
    },
    Kernel {
        source: Error,
    },
    MetadataError(String),
    NotInitialized,
    NotInitializedWithFiles(String),
    ChangeDataNotRecorded {
        version: i64,
        start: i64,
        end: i64,
    },
    ChangeDataNotEnabled {
        version: i64,
    },
    ChangeDataInvalidVersionRange {
        start: i64,
        end: i64,
    },
}

Delta Table specific error

Variants

KernelError(Error)

Protocol

Fields

source: ProtocolError

ObjectStore

Error returned when reading the delta log object failed.

Fields

source: Error

Storage error details when reading the delta log object failed.

Parquet

Error returned when parsing checkpoint parquet.

Fields

source: ParquetError

Parquet error details returned when reading the checkpoint failed.

Arrow

Error returned when converting the schema in Arrow format failed.

Fields

source: ArrowError

Arrow error details returned when converting the schema in Arrow format failed

InvalidJsonLog

Error returned when the log record has an invalid JSON.

Fields

json_err: Error

JSON error details returned when parsing the record JSON.

line: String

invalid log entry content.

version: i64

corresponding table version for the log file.

InvalidStatsJson

Error returned when the log contains invalid stats JSON.

Fields

json_err: Error

JSON error details returned when parsing the stats JSON.

InvalidInvariantJson

Error returned when the log contains invalid stats JSON.

Fields

json_err: Error

JSON error details returned when parsing the invariant expression JSON.

line: String

Invariant expression.

InvalidVersion(i64)

Error returned when the DeltaTable has an invalid version.

MissingDataFile

Error returned when the DeltaTable has no data files.

Fields

source: Error

Source error details returned when the DeltaTable has no data files.

path: String

The Path used of the DeltaTable

InvalidDateTimeString

Error returned when the datetime string is invalid for a conversion.

Fields

source: ParseError

Parse error details returned of the datetime string parse error.

InvalidData

Error returned when attempting to write bad data to the table

Fields

violations: Vec<String>

Action error details returned of the invalid action.

NotATable(String)

Error returned when it is not a DeltaTable.

NoMetadata

Error returned when no metadata was found in the DeltaTable.

NoSchema

Error returned when no schema was found in the DeltaTable.

LoadPartitions

Error returned when no partition was found in the DeltaTable.

SchemaMismatch

Error returned when writes are attempted with data that doesn’t match the schema of the table

Fields

msg: String

Information about the mismatch

PartitionError

Error returned when a partition is not formatted as a Hive Partition.

Fields

partition: String

The malformed partition used.

InvalidPartitionFilter

Error returned when a invalid partition filter was found.

Fields

partition_filter: String

The invalid partition filter used.

ColumnsNotPartitioned

Error returned when a partition filter uses a nonpartitioned column.

Fields

nonpartitioned_columns: Vec<String>

The columns used in the partition filter that is not partitioned

Io

Error returned when a line from log record is invalid.

Fields

source: Error

Source error details returned while reading the log record.

CommitValidation

Error raised while preparing a commit

Fields

source: CommitBuilderError

The source error

Transaction

Error raised while commititng transaction

Fields

source: TransactionError

The source error

VersionAlreadyExists(i64)

Error returned when transaction is failed to be committed because given version already exists.

VersionMismatch(i64, i64)

Error returned when user attempts to commit actions that don’t belong to the next version.

MissingFeature

A Feature is missing to perform operation

Fields

feature: &'static str

Name of the missing feature

url: String

Storage location url

InvalidTableLocation(String)

A Feature is missing to perform operation

SerializeLogJson

Generic Delta Table error

Fields

json_err: Error

JSON serialization error

SerializeSchemaJson

Generic Delta Table error

Fields

json_err: Error

JSON serialization error

Generic(String)

Generic Delta Table error

GenericError

Generic Delta Table error

Fields

source: Box<dyn Error + Send + Sync + 'static>

Source error

Kernel

Fields

source: Error

MetadataError(String)

NotInitialized

NotInitializedWithFiles(String)

ChangeDataNotRecorded

Fields

version: i64

start: i64

end: i64

ChangeDataNotEnabled

Fields

version: i64

ChangeDataInvalidVersionRange

Fields

start: i64

end: i64

Implementations

impl DeltaTableError

pub fn not_a_table(path: impl AsRef<str>) -> Self

Crate a NotATable Error with message for given path.

pub fn generic(msg: impl ToString) -> Self

Create a Generic error with the given message.

Trait Implementations

impl Debug for DeltaTableError

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

Formats the value using the given formatter.

impl Display for DeltaTableError

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

Formats the value using the given formatter.

impl Error for DeltaTableError

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 DeltaTableError

fn from(source: ArrowError) -> Self

Converts to this type from the input type.

impl From<CommitBuilderError> for DeltaTableError

fn from(err: CommitBuilderError) -> Self

Converts to this type from the input type.

impl From<DataFusionError> for DeltaTableError

fn from(err: DataFusionError) -> Self

Converts to this type from the input type.

impl From<DeltaTableError> for DataFusionError

fn from(err: DeltaTableError) -> Self

Converts to this type from the input type.

impl From<Error> for DeltaTableError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for DeltaTableError

fn from(source: ObjectStoreError) -> Self

Converts to this type from the input type.

impl From<Error> for DeltaTableError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for DeltaTableError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<Error> for DeltaTableError

fn from(err: Error) -> Self

Converts to this type from the input type.

impl From<Error> for DeltaTableError

fn from(value: Error) -> Self

Converts to this type from the input type.

impl From<ParquetError> for DeltaTableError

fn from(source: ParquetError) -> Self

Converts to this type from the input type.

impl From<ParseError> for DeltaTableError

fn from(source: ParseError) -> Self

Converts to this type from the input type.

impl From<ProtocolError> for DeltaTableError

fn from(value: ProtocolError) -> Self

Converts to this type from the input type.

impl From<TransactionError> for DeltaTableError

fn from(err: TransactionError) -> Self

Converts to this type from the input type.