|
20 | 20 | import static com.google.cloud.spanner.SpannerExceptionFactory.newSpannerExceptionForCancellation; |
21 | 21 | import static com.google.common.base.Preconditions.checkArgument; |
22 | 22 | import static com.google.common.base.Preconditions.checkNotNull; |
23 | | -import java.io.IOException; |
24 | | -import java.util.ArrayList; |
25 | | -import java.util.Collection; |
26 | | -import java.util.Collections; |
27 | | -import java.util.HashMap; |
28 | | -import java.util.List; |
29 | | -import java.util.Map; |
30 | | -import java.util.Random; |
31 | | -import java.util.concurrent.Callable; |
32 | | -import java.util.concurrent.CountDownLatch; |
33 | | -import java.util.concurrent.ExecutionException; |
34 | | -import java.util.concurrent.Executor; |
35 | | -import java.util.concurrent.TimeUnit; |
36 | | -import java.util.logging.Level; |
37 | | -import java.util.logging.Logger; |
38 | | -import javax.annotation.Nullable; |
39 | | -import javax.annotation.concurrent.GuardedBy; |
| 23 | + |
40 | 24 | import com.google.api.client.util.BackOff; |
41 | 25 | import com.google.api.client.util.ExponentialBackOff; |
42 | 26 | import com.google.api.gax.paging.Page; |
|
48 | 32 | import com.google.cloud.spanner.AbstractReadContext.MultiUseReadOnlyTransaction; |
49 | 33 | import com.google.cloud.spanner.AbstractReadContext.SingleReadContext; |
50 | 34 | import com.google.cloud.spanner.AbstractReadContext.SingleUseReadOnlyTransaction; |
| 35 | +import com.google.cloud.spanner.TransactionRunnerImpl.TransactionContextImpl; |
51 | 36 | import com.google.cloud.spanner.spi.v1.SpannerRpc; |
52 | 37 | import com.google.cloud.spanner.spi.v1.SpannerRpc.Paginated; |
53 | 38 | import com.google.common.base.Preconditions; |
|
72 | 57 | import io.opencensus.trace.Span; |
73 | 58 | import io.opencensus.trace.Tracer; |
74 | 59 | import io.opencensus.trace.Tracing; |
| 60 | +import java.io.IOException; |
| 61 | +import java.util.ArrayList; |
| 62 | +import java.util.Collection; |
| 63 | +import java.util.Collections; |
| 64 | +import java.util.HashMap; |
| 65 | +import java.util.List; |
| 66 | +import java.util.Map; |
| 67 | +import java.util.Random; |
| 68 | +import java.util.concurrent.Callable; |
| 69 | +import java.util.concurrent.CountDownLatch; |
| 70 | +import java.util.concurrent.ExecutionException; |
| 71 | +import java.util.concurrent.Executor; |
| 72 | +import java.util.concurrent.TimeUnit; |
| 73 | +import java.util.logging.Level; |
| 74 | +import java.util.logging.Logger; |
| 75 | +import javax.annotation.Nullable; |
| 76 | +import javax.annotation.concurrent.GuardedBy; |
75 | 77 |
|
76 | 78 | /** Default implementation of the Cloud Spanner interface. */ |
77 | 79 | class SpannerImpl extends BaseService<SpannerOptions> implements Spanner { |
|
0 commit comments