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:
  • 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