io.delta.kernel.exceptions

Class ConcurrentTransactionException

Object

Throwable

Exception

RuntimeException

io.delta.kernel.exceptions.KernelException

io.delta.kernel.exceptions.ConcurrentWriteException

io.delta.kernel.exceptions.ConcurrentTransactionException

All Implemented Interfaces:

java.io.Serializable

@Evolving
public class ConcurrentTransactionException
extends ConcurrentWriteException

Thrown when concurrent transaction both attempt to update the table with same transaction identifier set through TransactionBuilder.withTransactionId(Engine, String, long) (String)}.

Incremental processing systems (e.g., streaming systems) that track progress using their own application-specific versions need to record what progress has been made, in order to avoid duplicating data in the face of failures and retries during writes. For more information refer to the Delta protocol section Transaction Identifiers

Since:

3.2.0

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConcurrentTransactionException(String appId, long txnVersion, long lastUpdated)

Method Summary

Methods inherited from class Throwable

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

Methods inherited from class Object

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

Constructor Detail

ConcurrentTransactionException

public ConcurrentTransactionException(String appId,
                                      long txnVersion,
                                      long lastUpdated)