Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Regenerate spanner client #4647

Merged
merged 1 commit into from
Mar 6, 2019
+5,482 −164
Merged

Regenerate spanner client #4647

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
218 changes: 207 additions & 11 deletions ...pi-grpc/grpc-google-cloud-spanner-v1/src/main/java/com/google/spanner/v1/SpannerGrpc.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -325,6 +325,61 @@ private SpannerGrpc() {}
return getExecuteStreamingSqlMethod;
}

@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getExecuteBatchDmlMethod()} instead.
public static final io.grpc.MethodDescriptor<
com.google.spanner.v1.ExecuteBatchDmlRequest,
com.google.spanner.v1.ExecuteBatchDmlResponse>
METHOD_EXECUTE_BATCH_DML = getExecuteBatchDmlMethodHelper();

private static volatile io.grpc.MethodDescriptor<
com.google.spanner.v1.ExecuteBatchDmlRequest,
com.google.spanner.v1.ExecuteBatchDmlResponse>
getExecuteBatchDmlMethod;

@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
public static io.grpc.MethodDescriptor<
com.google.spanner.v1.ExecuteBatchDmlRequest,
com.google.spanner.v1.ExecuteBatchDmlResponse>
getExecuteBatchDmlMethod() {
return getExecuteBatchDmlMethodHelper();
}

private static io.grpc.MethodDescriptor<
com.google.spanner.v1.ExecuteBatchDmlRequest,
com.google.spanner.v1.ExecuteBatchDmlResponse>
getExecuteBatchDmlMethodHelper() {
io.grpc.MethodDescriptor<
com.google.spanner.v1.ExecuteBatchDmlRequest,
com.google.spanner.v1.ExecuteBatchDmlResponse>
getExecuteBatchDmlMethod;
if ((getExecuteBatchDmlMethod = SpannerGrpc.getExecuteBatchDmlMethod) == null) {
synchronized (SpannerGrpc.class) {
if ((getExecuteBatchDmlMethod = SpannerGrpc.getExecuteBatchDmlMethod) == null) {
SpannerGrpc.getExecuteBatchDmlMethod =
getExecuteBatchDmlMethod =
io.grpc.MethodDescriptor
.<com.google.spanner.v1.ExecuteBatchDmlRequest,
com.google.spanner.v1.ExecuteBatchDmlResponse>
newBuilder()
.setType(io.grpc.MethodDescriptor.MethodType.UNARY)
.setFullMethodName(
generateFullMethodName("google.spanner.v1.Spanner", "ExecuteBatchDml"))
.setSampledToLocalTracing(true)
.setRequestMarshaller(
io.grpc.protobuf.ProtoUtils.marshaller(
com.google.spanner.v1.ExecuteBatchDmlRequest.getDefaultInstance()))
.setResponseMarshaller(
io.grpc.protobuf.ProtoUtils.marshaller(
com.google.spanner.v1.ExecuteBatchDmlResponse.getDefaultInstance()))
.setSchemaDescriptor(new SpannerMethodDescriptorSupplier("ExecuteBatchDml"))
.build();
}
}
}
return getExecuteBatchDmlMethod;
}

@io.grpc.ExperimentalApi("https://github.com/grpc/grpc-java/issues/1901")
@java.lang.Deprecated // Use {@link #getReadMethod()} instead.
public static final io.grpc.MethodDescriptor<
Expand Down Expand Up @@ -757,7 +812,9 @@ public void listSessions(
*
*
* <pre>
* Ends a session, releasing server resources associated with it.
* Ends a session, releasing server resources associated with it. This will
* asynchronously trigger cancellation of any operations that are running with
* this session.
* </pre>
*/
public void deleteSession(
Expand Down Expand Up @@ -806,6 +863,35 @@ public void executeStreamingSql(
asyncUnimplementedUnaryCall(getExecuteStreamingSqlMethodHelper(), responseObserver);
}

/**
*
*
* <pre>
* Executes a batch of SQL DML statements. This method allows many statements
* to be run with lower latency than submitting them sequentially with
* [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
* Statements are executed in order, sequentially.
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
* [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
* statement fails, its error status will be returned as part of the
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
* stop at the first failed statement; the remaining statements will not run.
* ExecuteBatchDml is expected to return an OK status with a response even if
* there was an error while processing one of the DML statements. Clients must
* inspect response.status to determine if there were any errors while
* processing the request.
* See more details in
* [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
* </pre>
*/
public void executeBatchDml(
com.google.spanner.v1.ExecuteBatchDmlRequest request,
io.grpc.stub.StreamObserver<com.google.spanner.v1.ExecuteBatchDmlResponse>
responseObserver) {
asyncUnimplementedUnaryCall(getExecuteBatchDmlMethodHelper(), responseObserver);
}

/**
*
*
Expand Down Expand Up @@ -991,6 +1077,13 @@ public final io.grpc.ServerServiceDefinition bindService() {
com.google.spanner.v1.ExecuteSqlRequest,
com.google.spanner.v1.PartialResultSet>(
this, METHODID_EXECUTE_STREAMING_SQL)))
.addMethod(
getExecuteBatchDmlMethodHelper(),
asyncUnaryCall(
new MethodHandlers<
com.google.spanner.v1.ExecuteBatchDmlRequest,
com.google.spanner.v1.ExecuteBatchDmlResponse>(
this, METHODID_EXECUTE_BATCH_DML)))
.addMethod(
getReadMethodHelper(),
asyncUnaryCall(
Expand Down Expand Up @@ -1129,7 +1222,9 @@ public void listSessions(
*
*
* <pre>
* Ends a session, releasing server resources associated with it.
* Ends a session, releasing server resources associated with it. This will
* asynchronously trigger cancellation of any operations that are running with
* this session.
* </pre>
*/
public void deleteSession(
Expand Down Expand Up @@ -1187,6 +1282,38 @@ public void executeStreamingSql(
responseObserver);
}

/**
*
*
* <pre>
* Executes a batch of SQL DML statements. This method allows many statements
* to be run with lower latency than submitting them sequentially with
* [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
* Statements are executed in order, sequentially.
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
* [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
* statement fails, its error status will be returned as part of the
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
* stop at the first failed statement; the remaining statements will not run.
* ExecuteBatchDml is expected to return an OK status with a response even if
* there was an error while processing one of the DML statements. Clients must
* inspect response.status to determine if there were any errors while
* processing the request.
* See more details in
* [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
* </pre>
*/
public void executeBatchDml(
com.google.spanner.v1.ExecuteBatchDmlRequest request,
io.grpc.stub.StreamObserver<com.google.spanner.v1.ExecuteBatchDmlResponse>
responseObserver) {
asyncUnaryCall(
getChannel().newCall(getExecuteBatchDmlMethodHelper(), getCallOptions()),
request,
responseObserver);
}

/**
*
*
Expand Down Expand Up @@ -1436,7 +1563,9 @@ public com.google.spanner.v1.ListSessionsResponse listSessions(
*
*
* <pre>
* Ends a session, releasing server resources associated with it.
* Ends a session, releasing server resources associated with it. This will
* asynchronously trigger cancellation of any operations that are running with
* this session.
* </pre>
*/
public com.google.protobuf.Empty deleteSession(
Expand Down Expand Up @@ -1485,6 +1614,34 @@ public java.util.Iterator<com.google.spanner.v1.PartialResultSet> executeStreami
getChannel(), getExecuteStreamingSqlMethodHelper(), getCallOptions(), request);
}

/**
*
*
* <pre>
* Executes a batch of SQL DML statements. This method allows many statements
* to be run with lower latency than submitting them sequentially with
* [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
* Statements are executed in order, sequentially.
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
* [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
* statement fails, its error status will be returned as part of the
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
* stop at the first failed statement; the remaining statements will not run.
* ExecuteBatchDml is expected to return an OK status with a response even if
* there was an error while processing one of the DML statements. Clients must
* inspect response.status to determine if there were any errors while
* processing the request.
* See more details in
* [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
* </pre>
*/
public com.google.spanner.v1.ExecuteBatchDmlResponse executeBatchDml(
com.google.spanner.v1.ExecuteBatchDmlRequest request) {
return blockingUnaryCall(
getChannel(), getExecuteBatchDmlMethodHelper(), getCallOptions(), request);
}

/**
*
*
Expand Down Expand Up @@ -1710,7 +1867,9 @@ protected SpannerFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions c
*
*
* <pre>
* Ends a session, releasing server resources associated with it.
* Ends a session, releasing server resources associated with it. This will
* asynchronously trigger cancellation of any operations that are running with
* this session.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty>
Expand Down Expand Up @@ -1742,6 +1901,35 @@ protected SpannerFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions c
getChannel().newCall(getExecuteSqlMethodHelper(), getCallOptions()), request);
}

/**
*
*
* <pre>
* Executes a batch of SQL DML statements. This method allows many statements
* to be run with lower latency than submitting them sequentially with
* [ExecuteSql][google.spanner.v1.Spanner.ExecuteSql].
* Statements are executed in order, sequentially.
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse] will contain a
* [ResultSet][google.spanner.v1.ResultSet] for each DML statement that has successfully executed. If a
* statement fails, its error status will be returned as part of the
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse]. Execution will
* stop at the first failed statement; the remaining statements will not run.
* ExecuteBatchDml is expected to return an OK status with a response even if
* there was an error while processing one of the DML statements. Clients must
* inspect response.status to determine if there were any errors while
* processing the request.
* See more details in
* [ExecuteBatchDmlRequest][Spanner.ExecuteBatchDmlRequest] and
* [ExecuteBatchDmlResponse][Spanner.ExecuteBatchDmlResponse].
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.spanner.v1.ExecuteBatchDmlResponse>
executeBatchDml(com.google.spanner.v1.ExecuteBatchDmlRequest request) {
return futureUnaryCall(
getChannel().newCall(getExecuteBatchDmlMethodHelper(), getCallOptions()), request);
}

/**
*
*
Expand Down Expand Up @@ -1879,13 +2067,14 @@ public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Em
private static final int METHODID_DELETE_SESSION = 3;
private static final int METHODID_EXECUTE_SQL = 4;
private static final int METHODID_EXECUTE_STREAMING_SQL = 5;
private static final int METHODID_READ = 6;
private static final int METHODID_STREAMING_READ = 7;
private static final int METHODID_BEGIN_TRANSACTION = 8;
private static final int METHODID_COMMIT = 9;
private static final int METHODID_ROLLBACK = 10;
private static final int METHODID_PARTITION_QUERY = 11;
private static final int METHODID_PARTITION_READ = 12;
private static final int METHODID_EXECUTE_BATCH_DML = 6;
private static final int METHODID_READ = 7;
private static final int METHODID_STREAMING_READ = 8;
private static final int METHODID_BEGIN_TRANSACTION = 9;
private static final int METHODID_COMMIT = 10;
private static final int METHODID_ROLLBACK = 11;
private static final int METHODID_PARTITION_QUERY = 12;
private static final int METHODID_PARTITION_READ = 13;

private static final class MethodHandlers<Req, Resp>
implements io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>,
Expand Down Expand Up @@ -1936,6 +2125,12 @@ public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserv
(io.grpc.stub.StreamObserver<com.google.spanner.v1.PartialResultSet>)
responseObserver);
break;
case METHODID_EXECUTE_BATCH_DML:
serviceImpl.executeBatchDml(
(com.google.spanner.v1.ExecuteBatchDmlRequest) request,
(io.grpc.stub.StreamObserver<com.google.spanner.v1.ExecuteBatchDmlResponse>)
responseObserver);
break;
case METHODID_READ:
serviceImpl.read(
(com.google.spanner.v1.ReadRequest) request,
Expand Down Expand Up @@ -2042,6 +2237,7 @@ public static io.grpc.ServiceDescriptor getServiceDescriptor() {
.addMethod(getDeleteSessionMethodHelper())
.addMethod(getExecuteSqlMethodHelper())
.addMethod(getExecuteStreamingSqlMethodHelper())
.addMethod(getExecuteBatchDmlMethodHelper())
.addMethod(getReadMethodHelper())
.addMethod(getStreamingReadMethodHelper())
.addMethod(getBeginTransactionMethodHelper())
Expand Down
Loading