Interface AsyncTransactionManager.AsyncTransactionStep<I,O> (6.25.1)

Version 6.25.1

• 6.80.1 (latest)
• 6.79.0
• 6.77.0
• 6.74.1
• 6.72.0
• 6.71.0
• 6.69.0
• 6.68.0
• 6.66.0
• 6.65.1
• 6.62.0
• 6.60.0
• 6.58.0
• 6.57.0
• 6.56.0
• 6.55.0
• 6.54.0
• 6.53.0
• 6.52.1
• 6.51.0
• 6.50.1
• 6.49.0
• 6.25.1
• 6.24.0
• 6.23.4
• 6.22.0
• 6.21.2
• 6.20.0
• 6.19.1
• 6.18.0
• 6.17.4
• 6.14.1

public static interface AsyncTransactionManager.AsyncTransactionStep<I,O> extends ApiFuture<O>

AsyncTransactionStep is returned by TransactionContextFuture#then(AsyncTransactionFunction) and AsyncTransactionStep#then(AsyncTransactionFunction) and allows transaction steps that should be executed serially to be chained together. Each step can contain one or more statements that may execute in parallel.

Example usage:

 final String column = "FirstName";
 final long singerId = 1L;
 AsyncTransactionManager manager = client.transactionManagerAsync();
 TransactionContextFuture txnFuture = manager.beginAsync();
 txnFuture
   .then((transaction, ignored) ->
     transaction.readRowAsync("Singers", Key.of(singerId), Collections.singleton(column)),
     executor)
   .then((transaction, row) ->
     transaction.bufferAsync(
         Mutation.newUpdateBuilder("Singers")
           .set(column).to(row.getString(column).toUpperCase())
           .build()),
     executor)
   .commitAsync();
 

Implements

com.google.api.core.ApiFuture<O>

Type Parameters
Name	Description
I
O

Methods

<RES>then(AsyncTransactionManager.AsyncTransactionFunction<O,RES> next, Executor executor)

public abstract AsyncTransactionManager.AsyncTransactionStep<O,RES> <RES>then(AsyncTransactionManager.AsyncTransactionFunction<O,RES> next, Executor executor)

Adds a step to the transaction chain that should be executed using the specified executor. This step is guaranteed to be executed only after the previous step executed successfully. MoreExecutors#directExecutor() can be be used for lightweight functions, but should be avoided for heavy or blocking operations. See also ListenableFuture#addListener(Runnable, Executor) for further information.

Parameters
Name	Description
next	AsyncTransactionFunction<O,RES>
executor	Executor

Returns
Type	Description
AsyncTransactionStep<O,RES>

commitAsync()

public abstract AsyncTransactionManager.CommitTimestampFuture commitAsync()

Commits the transaction and returns a CommitTimestampFuture that will return the commit timestamp of the transaction, or throw the first uncaught exception in the transaction chain as an ExecutionException.

Returns
Type	Description
AsyncTransactionManager.CommitTimestampFuture