Merged

perf: use RPC for PDML #287

Show file tree
Hide file tree
Changes from 1 commit
Show all changes
14 commits
Select commit Hold shift + click to select a range
8f67dd7
perf: use RPC for PDML
olavloiteJun 19, 2020
7981059
fix: reset resume token for each tx
olavloiteJun 19, 2020
5235a38
cleanup: remove test code
olavloiteJun 19, 2020
51930fa
fix: retry depening on resume token
olavloiteJun 20, 2020
3ff3ce4
fix: remove unused attempt param
olavloiteJun 20, 2020
82ca881
fix: fix check for resume token
olavloiteJun 22, 2020
0808d9f
fix: keep track of total timeout
olavloiteJun 24, 2020
223bd1a
fix: clirr build failure
olavloiteJun 24, 2020
5689e53
cleanup: add comments + remove unused code
olavloiteJun 24, 2020
77c9cdf
tests: add missing exec time
olavloiteJun 24, 2020
52f91e3
chore: run formatter
olavloiteJun 24, 2020
32acacb
chore: remove unnecessary null check
olavloiteJun 30, 2020
9e803a5
Merge branch 'master' into -pdml
olavloiteJun 30, 2020
850e4a1
tests: add missing exec time
olavloiteJun 30, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Failed to load files.
PrevPrevious commit
Next Next commit
fix: clirr build failure
  • Loading branch information
@olavloite
olavloite committedJun 24, 2020
commit 223bd1ae59bcdb05a18fe4bcb76e73a0f076dce7
Original file line numberDiff line numberDiff line change
Expand Up@@ -180,6 +180,6 @@
<difference>
<differenceType>7012</differenceType>
<className>com/google/cloud/spanner/spi/v1/SpannerRpc</className>
<method>com.google.api.gax.rpc.ServerStream executePartitionedDml(com.google.spanner.v1.ExecuteSqlRequest, java.util.Map)</method>
<method>com.google.api.gax.rpc.ServerStream executePartitionedDml(com.google.spanner.v1.ExecuteSqlRequest, java.util.Map, org.threeten.bp.Duration)</method>
</difference>
</differences>
Original file line numberDiff line numberDiff line change
Expand Up@@ -304,7 +304,7 @@ public GapicSpannerRpc(final SpannerOptions options) {

// Set a keepalive time of 120 seconds to help long running
// commit GRPC calls succeed
.setKeepAliveTime(Duration.ofSeconds(GRPC_KEEPALIVE_SECONDS))
.setKeepAliveTime(Duration.ofSeconds(GRPC_KEEPALIVE_SECONDS * 1000))

// Then check if SpannerOptions provides an InterceptorProvider. Create a default
// SpannerInterceptorProvider if none is provided
Expand Down