包 io.delta.exceptions

类 ConcurrentTransactionException

Object

Throwable

Exception

RuntimeException

java.util.ConcurrentModificationException

org.apache.spark.sql.delta.DeltaConcurrentModificationException

io.delta.exceptions.DeltaConcurrentModificationException

org.apache.spark.sql.delta.ConcurrentTransactionException

io.delta.exceptions.ConcurrentTransactionException

所有已实现的接口：

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

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

:: 演进中 :

当并发事务都尝试更新相同的幂等事务时抛出。

自

1.0.0

另请参阅

• 序列化形式

构造器摘要

构造器

构造器	描述
ConcurrentTransactionException(String message)
ConcurrentTransactionException(String[] messageParameters)

方法摘要

修饰符及类型	方法	描述
String	getErrorClass()
String	getMessage()

从类 org.apache.spark.sql.delta.DeltaConcurrentModificationException 继承的方法

conflictType

从类 java.lang.Throwable继承的方法

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

从类 java.lang.Object 继承的方法

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

从接口 org.apache.spark.sql.delta.DeltaThrowable 继承的方法

getSqlState, isInternalError

从接口 org.apache.spark.sql.delta.DeltaThrowableConditionShim 继承的方法

getCondition

从接口 org.apache.spark.SparkThrowable 继承的方法

getMessageParameters, getQueryContext

构造器详细信息

ConcurrentTransactionException

public ConcurrentTransactionException(String message)

ConcurrentTransactionException

public ConcurrentTransactionException(String[] messageParameters)

方法详情

getErrorClass

public String getErrorClass()

指定者

接口 org.apache.spark.sql.delta.DeltaThrowableConditionShim 中的 getErrorClass

指定者

接口 org.apache.spark.SparkThrowable 中的 getErrorClass

getMessage

public String getMessage()

覆盖

getMessage 在类 Throwable 中