Skip to content

Commit 81dbf49

Browse files
olavloitesduskis
authored andcommitted
---
yaml --- r: 27807 b: refs/heads/autosynth-pubsub c: 2eaa9f4 h: refs/heads/master i: 27805: 8556880 27803: 5fb7076 27799: 8030425 27791: 33d9a46 27775: e8670b9
1 parent 7c9eef8 commit 81dbf49

2 files changed

Lines changed: 1 addition & 20 deletions

File tree

  • branches/autosynth-pubsub/google-cloud-clients/google-cloud-spanner/src/main/java/com/google/cloud/spanner

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ refs/tags/v0.67.0: 30b56f02092efc6f3c3667650ea8b8825003e0b7
114114
refs/heads/autosynth-compute: c0ad4e5b54b2b167d47e508ca215c039404837d3
115115
refs/heads/autosynth-container: d17e1a76a903f9e05eba56a9bf5d12c1b15b67d7
116116
refs/heads/autosynth-monitoring: e66569bd7358a90d17097f90cf8c70dbeeb048cf
117-
refs/heads/autosynth-pubsub: 20bc33fa6d71ce9fab3b7a92e994f90be302674f
117+
refs/heads/autosynth-pubsub: 2eaa9f463c9f32dcd3a475975d88b87d924df3b4
118118
refs/heads/autosynth-video-intelligence: 376f1f5972d56c508e9755b817ac478e84b219de
119119
refs/heads/autosynth-vision: c99f959b6acf4840e473f2e67144d00ec52875e5
120120
refs/heads/spanner: b01127f885b4611bf1852abb0ce481eeb7fcc131

branches/autosynth-pubsub/google-cloud-clients/google-cloud-spanner/src/main/java/com/google/cloud/spanner/SpannerImpl.java

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import com.google.api.client.util.BackOff;
2525
import com.google.api.client.util.ExponentialBackOff;
2626
import com.google.api.gax.paging.Page;
27-
import com.google.api.pathtemplate.PathTemplate;
2827
import com.google.cloud.BaseService;
2928
import com.google.cloud.PageImpl;
3029
import com.google.cloud.PageImpl.NextPageFetcher;
@@ -36,9 +35,6 @@
3635
import com.google.common.collect.Maps;
3736
import com.google.common.util.concurrent.Futures;
3837
import com.google.common.util.concurrent.ListenableFuture;
39-
import com.google.protobuf.Any;
40-
import com.google.protobuf.InvalidProtocolBufferException;
41-
import com.google.protobuf.Message;
4238
import io.grpc.Context;
4339
import io.opencensus.common.Scope;
4440
import io.opencensus.trace.AttributeValue;
@@ -66,11 +62,6 @@
6662
class SpannerImpl extends BaseService<SpannerOptions> implements Spanner {
6763
private static final int MIN_BACKOFF_MS = 1000;
6864
private static final int MAX_BACKOFF_MS = 32000;
69-
private static final PathTemplate OP_NAME_TEMPLATE =
70-
PathTemplate.create(
71-
"projects/{project}/instances/{instance}/databases/{database}/operations/{operation}");
72-
private static final PathTemplate PROJECT_NAME_TEMPLATE =
73-
PathTemplate.create("projects/{project}");
7465

7566
private static final Logger logger = Logger.getLogger(SpannerImpl.class.getName());
7667
private static final Tracer tracer = Tracing.getTracer();
@@ -343,16 +334,6 @@ Object value() {
343334
return ImmutableMap.copyOf(tmp);
344335
}
345336

346-
private static <T extends Message> T unpack(Any response, Class<T> clazz)
347-
throws SpannerException {
348-
try {
349-
return response.unpack(clazz);
350-
} catch (InvalidProtocolBufferException e) {
351-
throw SpannerExceptionFactory.newSpannerException(
352-
ErrorCode.INTERNAL, "Error unpacking response", e);
353-
}
354-
}
355-
356337
abstract static class PageFetcher<S, T> implements NextPageFetcher<S> {
357338
private String nextPageToken;
358339

0 commit comments

Comments
 (0)