Package io.delta.exceptions

Class ConcurrentWriteException

Object

Throwable

Exception

RuntimeException

java.util.ConcurrentModificationException

org.apache.spark.sql.delta.DeltaConcurrentModificationException

io.delta.exceptions.DeltaConcurrentModificationException

org.apache.spark.sql.delta.ConcurrentWriteException

io.delta.exceptions.ConcurrentWriteException

All Implemented Interfaces:

Serializable, org.apache.spark.SparkThrowable, org.apache.spark.sql.delta.DeltaThrowable, org.apache.spark.sql.delta.DeltaThrowableConditionShim

public class ConcurrentWriteException
extends org.apache.spark.sql.delta.ConcurrentWriteException
implements org.apache.spark.sql.delta.DeltaThrowable

:: Evolving ::

Thrown when a concurrent transaction has written data after the current transaction read the table.

Since:

1.0.0

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ConcurrentWriteException(String message)
ConcurrentWriteException(String[] messageParameters)

Method Summary

Modifier and Type	Method	Description
String	getErrorClass()
String	getMessage()

Methods inherited from class org.apache.spark.sql.delta.DeltaConcurrentModificationException

conflictType

Methods inherited from class java.lang.Throwable

addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.delta.DeltaThrowable

getSqlState, isInternalError

Methods inherited from interface org.apache.spark.sql.delta.DeltaThrowableConditionShim

getCondition

Methods inherited from interface org.apache.spark.SparkThrowable

getMessageParameters, getQueryContext

Constructor Details

ConcurrentWriteException

public ConcurrentWriteException(String message)

ConcurrentWriteException

public ConcurrentWriteException(String[] messageParameters)

Method Details

getErrorClass

public String getErrorClass()

Specified by:

getErrorClass in interface org.apache.spark.sql.delta.DeltaThrowableConditionShim

Specified by:

getErrorClass in interface org.apache.spark.SparkThrowable

getMessage

public String getMessage()

Overrides:

getMessage in class Throwable