包 io.delta.exceptions

类 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

所有已实现的接口：

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

:: 演进中 :

当并发事务在当前事务读取表后写入数据时抛出。

自

1.0.0

另请参阅

• 序列化形式

构造器摘要

构造器

构造器	描述
ConcurrentWriteException(String message)
ConcurrentWriteException(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

构造器详细信息

ConcurrentWriteException

public ConcurrentWriteException(String message)

ConcurrentWriteException

public ConcurrentWriteException(String[] messageParameters)

方法详情

getErrorClass

public String getErrorClass()

指定者

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

指定者

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

getMessage

public String getMessage()

覆盖

getMessage 在类 Throwable中