Enum CommitConflictError

pub enum CommitConflictError {
    ConcurrentAppend,
    ConcurrentDeleteRead,
    ConcurrentDeleteDelete,
    MetadataChanged,
    ConcurrentTransaction,
    ProtocolChanged(String),
    UnsupportedWriterVersion(i32),
    UnsupportedReaderVersion(i32),
    CorruptedState {
        source: Box<dyn Error + Send + Sync + 'static>,
    },
    Predicate {
        source: Box<dyn Error + Send + Sync + 'static>,
    },
    NoMetadata,
}

Exceptions raised during commit conflict resolution

Variants

ConcurrentAppend

This exception occurs when a concurrent operation adds files in the same partition (or anywhere in an un-partitioned table) that your operation reads. The file additions can be caused by INSERT, DELETE, UPDATE, or MERGE operations.

ConcurrentDeleteRead

This exception occurs when a concurrent operation deleted a file that your operation read. Common causes are a DELETE, UPDATE, or MERGE operation that rewrites files.

ConcurrentDeleteDelete

This exception occurs when a concurrent operation deleted a file that your operation also deletes. This could be caused by two concurrent compaction operations rewriting the same files.

MetadataChanged

This exception occurs when a concurrent transaction updates the metadata of a Delta table. Common causes are ALTER TABLE operations or writes to your Delta table that update the schema of the table.

ConcurrentTransaction

If a streaming query using the same checkpoint location is started multiple times concurrently and tries to write to the Delta table at the same time. You should never have two streaming queries use the same checkpoint location and run at the same time.

ProtocolChanged(String)

This exception can occur in the following cases:

• When your Delta table is upgraded to a new version. For future operations to succeed you may need to upgrade your Delta Lake version.
• When multiple writers are creating or replacing a table at the same time.
• When multiple writers are writing to an empty path at the same time.

UnsupportedWriterVersion(i32)

Error returned when the table requires an unsupported writer version

UnsupportedReaderVersion(i32)

Error returned when the table requires an unsupported writer version

CorruptedState

Error returned when the snapshot has missing or corrupted data

Fields

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

Source error

Predicate

Error returned when evaluating predicate

Fields

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

Source error

NoMetadata

Error returned when no metadata was found in the DeltaTable.

Trait Implementations

impl Debug for CommitConflictError

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

Formats the value using the given formatter.

impl Display for CommitConflictError

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

Formats the value using the given formatter.

impl Error for CommitConflictError

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<CommitConflictError> for TransactionError

fn from(source: CommitConflictError) -> Self

Converts to this type from the input type.