File tree Expand file tree Collapse file tree 1 file changed +6
-0
lines changed
google-cloud-spanner/src/main/java/com/google/cloud/spanner Expand file tree Collapse file tree 1 file changed +6
-0
lines changed Original file line number Diff line number Diff line change 2121import com .google .api .core .ApiFuture ;
2222import com .google .api .core .ApiFutures ;
2323import com .google .api .core .SettableApiFuture ;
24+ import com .google .cloud .spanner .Options .TransactionOption ;
2425import com .google .cloud .spanner .SessionClient .SessionConsumer ;
2526import com .google .cloud .spanner .SpannerException .ResourceNotFoundException ;
2627import com .google .common .annotations .VisibleForTesting ;
@@ -388,6 +389,11 @@ public ReadOnlyTransaction readOnlyTransaction(TimestampBound bound) {
388389 return createMultiplexedSessionTransaction (false ).readOnlyTransaction (bound );
389390 }
390391
392+ @ Override
393+ public TransactionRunner readWriteTransaction (TransactionOption ... options ) {
394+ return createMultiplexedSessionTransaction (false ).readWriteTransaction (options );
395+ }
396+
391397 /**
392398 * It is enough with one executor to maintain the multiplexed sessions in all the clients, as they
393399 * do not need to be updated often, and the maintenance task is light. The core pool size is set
You can’t perform that action at this time.
0 commit comments