Skip to content


= SetTransaction

SetTransaction is an <> that denotes the committed <> for an <>.

SetTransaction is <> when DeltaSink is requested to <> (for STREAMING UPDATE operation idempotence at query restart).

== [[creating-instance]] Creating SetTransaction Instance

SetTransaction takes the following to be created:

  • [[appId]] Application ID (e.g. streaming query ID)
  • [[version]] Version (e.g micro-batch ID)
  • [[lastUpdated]] Last Updated (optional) (e.g. milliseconds since the epoch)

== [[wrap]] wrap Method

[source, scala]

wrap: SingleAction

NOTE: wrap is part of the <> contract to wrap the action into a <> for serialization.

wrap simply creates a new <> with the txn field set to this SetTransaction.

Last update: 2020-09-24