io.delta.standalone.actions

Class SetTransaction

Object

io.delta.standalone.actions.SetTransaction

All Implemented Interfaces:

Action

public final class SetTransaction
extends Object
implements Action

Sets the committed version for a given application. Used to make operations like Operation.Name.STREAMING_UPDATE idempotent.

See Also:

Delta Transaction Log Protocol: Transaction Identifiers

Constructor Summary

Constructors

Constructor and Description
SetTransaction(String appId, long version, java.util.Optional<Long> lastUpdated)

Method Summary

Modifier and Type	Method and Description
String	getAppId()
java.util.Optional<Long>	getLastUpdated()
long	getVersion()

Methods inherited from class Object

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

Constructor Detail

SetTransaction

public SetTransaction(@Nonnull
                      String appId,
                      long version,
                      @Nonnull
                      java.util.Optional<Long> lastUpdated)

Method Detail

getAppId

@Nonnull
public String getAppId()

Returns:

the unique identifier for the application performing the transaction

getVersion

public long getVersion()

Returns:

the application-specific numeric identifier for this transaction

getLastUpdated

@Nonnull
public java.util.Optional<Long> getLastUpdated()

Returns:

the time when this transaction action was created, in milliseconds since the Unix epoch