Skip to content

Commit

Permalink
chore: update gax-java dependency to 1.62 (#925)
Browse files Browse the repository at this point in the history
This PR was generated using Autosynth. 🌈

Synth log will be available here:
https://source.cloud.google.com/results/invocations/77e7decc-0671-4107-bba3-3b77cda21db8/targets

- [ ] To automatically regenerate this PR, check this box.

PiperOrigin-RevId: 361377784
Source-Link: googleapis/googleapis@0e91521
  • Loading branch information
yoshi-automation committed Mar 8, 2021
1 parent ed33785 commit f7c645a
Show file tree
Hide file tree
Showing 6 changed files with 145 additions and 157 deletions.
Expand Up @@ -16,14 +16,6 @@
package com.google.cloud.bigquery.storage.v1;

import static io.grpc.MethodDescriptor.generateFullMethodName;
import static io.grpc.stub.ClientCalls.asyncServerStreamingCall;
import static io.grpc.stub.ClientCalls.asyncUnaryCall;
import static io.grpc.stub.ClientCalls.blockingServerStreamingCall;
import static io.grpc.stub.ClientCalls.blockingUnaryCall;
import static io.grpc.stub.ClientCalls.futureUnaryCall;
import static io.grpc.stub.ServerCalls.asyncServerStreamingCall;
import static io.grpc.stub.ServerCalls.asyncUnaryCall;
import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;

/**
*
Expand Down Expand Up @@ -260,7 +252,8 @@ public void createReadSession(
com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.ReadSession>
responseObserver) {
asyncUnimplementedUnaryCall(getCreateReadSessionMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getCreateReadSessionMethod(), responseObserver);
}

/**
Expand All @@ -279,7 +272,7 @@ public void readRows(
com.google.cloud.bigquery.storage.v1.ReadRowsRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.ReadRowsResponse>
responseObserver) {
asyncUnimplementedUnaryCall(getReadRowsMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getReadRowsMethod(), responseObserver);
}

/**
Expand All @@ -303,29 +296,30 @@ public void splitReadStream(
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>
responseObserver) {
asyncUnimplementedUnaryCall(getSplitReadStreamMethod(), responseObserver);
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getSplitReadStreamMethod(), responseObserver);
}

@java.lang.Override
public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateReadSessionMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest,
com.google.cloud.bigquery.storage.v1.ReadSession>(
this, METHODID_CREATE_READ_SESSION)))
.addMethod(
getReadRowsMethod(),
asyncServerStreamingCall(
io.grpc.stub.ServerCalls.asyncServerStreamingCall(
new MethodHandlers<
com.google.cloud.bigquery.storage.v1.ReadRowsRequest,
com.google.cloud.bigquery.storage.v1.ReadRowsResponse>(
this, METHODID_READ_ROWS)))
.addMethod(
getSplitReadStreamMethod(),
asyncUnaryCall(
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest,
com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>(
Expand Down Expand Up @@ -379,7 +373,7 @@ public void createReadSession(
com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.ReadSession>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()),
request,
responseObserver);
Expand All @@ -401,7 +395,7 @@ public void readRows(
com.google.cloud.bigquery.storage.v1.ReadRowsRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.ReadRowsResponse>
responseObserver) {
asyncServerStreamingCall(
io.grpc.stub.ClientCalls.asyncServerStreamingCall(
getChannel().newCall(getReadRowsMethod(), getCallOptions()), request, responseObserver);
}

Expand All @@ -426,7 +420,7 @@ public void splitReadStream(
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>
responseObserver) {
asyncUnaryCall(
io.grpc.stub.ClientCalls.asyncUnaryCall(
getChannel().newCall(getSplitReadStreamMethod(), getCallOptions()),
request,
responseObserver);
Expand Down Expand Up @@ -477,7 +471,7 @@ protected BigQueryReadBlockingStub build(
*/
public com.google.cloud.bigquery.storage.v1.ReadSession createReadSession(
com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) {
return blockingUnaryCall(
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateReadSessionMethod(), getCallOptions(), request);
}

Expand All @@ -495,7 +489,7 @@ public com.google.cloud.bigquery.storage.v1.ReadSession createReadSession(
*/
public java.util.Iterator<com.google.cloud.bigquery.storage.v1.ReadRowsResponse> readRows(
com.google.cloud.bigquery.storage.v1.ReadRowsRequest request) {
return blockingServerStreamingCall(
return io.grpc.stub.ClientCalls.blockingServerStreamingCall(
getChannel(), getReadRowsMethod(), getCallOptions(), request);
}

Expand All @@ -518,7 +512,8 @@ public java.util.Iterator<com.google.cloud.bigquery.storage.v1.ReadRowsResponse>
*/
public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStream(
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) {
return blockingUnaryCall(getChannel(), getSplitReadStreamMethod(), getCallOptions(), request);
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSplitReadStreamMethod(), getCallOptions(), request);
}
}

Expand Down Expand Up @@ -567,7 +562,7 @@ protected BigQueryReadFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.storage.v1.ReadSession>
createReadSession(com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()), request);
}

Expand All @@ -591,7 +586,7 @@ protected BigQueryReadFutureStub build(
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>
splitReadStream(com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) {
return futureUnaryCall(
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSplitReadStreamMethod(), getCallOptions()), request);
}
}
Expand Down

0 comments on commit f7c645a

Please sign in to comment.