Class 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
All Implemented Interfaces:
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
:: Evolving ::

Thrown when concurrent transaction both attempt to update the same idempotent transaction.

Since:
1.0.0
See Also:
  • Constructor Details

    • ConcurrentTransactionException

      public ConcurrentTransactionException(String message)
    • ConcurrentTransactionException

      public ConcurrentTransactionException(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