Skip to content

Commit

Permalink
Merge branch 'googleapis:main' into main
Browse files Browse the repository at this point in the history
  • Loading branch information
GaoleMeng committed Mar 30, 2023
2 parents 1726c85 + a9f8c7e commit 9b9e420
Show file tree
Hide file tree
Showing 23 changed files with 374 additions and 275 deletions.
15 changes: 15 additions & 0 deletions CHANGELOG.md
@@ -1,5 +1,20 @@
# Changelog

## [2.34.2](https://github.com/googleapis/java-bigquerystorage/compare/v2.34.1...v2.34.2) (2023-03-30)


### Bug Fixes

* Correct AppendSerializtionError typo ([#2037](https://github.com/googleapis/java-bigquerystorage/issues/2037)) ([e67e913](https://github.com/googleapis/java-bigquerystorage/commit/e67e913f34fda4f4cc523c0248e5344232c0b736))


### Dependencies

* Update dependency com.google.cloud:google-cloud-bigquery to v2.24.0 ([#2054](https://github.com/googleapis/java-bigquerystorage/issues/2054)) ([e3156c7](https://github.com/googleapis/java-bigquerystorage/commit/e3156c7b525f7df2f3fe756f096e7fb1352fae8e))
* Update dependency com.google.cloud:google-cloud-bigquery to v2.24.1 ([#2056](https://github.com/googleapis/java-bigquerystorage/issues/2056)) ([a989ac6](https://github.com/googleapis/java-bigquerystorage/commit/a989ac63d813cc98dcc13200a950fe3edad10bdf))
* Update dependency com.google.cloud:google-cloud-bigquery to v2.24.3 ([#2058](https://github.com/googleapis/java-bigquerystorage/issues/2058)) ([9346667](https://github.com/googleapis/java-bigquerystorage/commit/934666737a92ec3220c6a186cc1af0f1adabb00c))
* Update dependency com.google.cloud:google-cloud-shared-dependencies to v3.6.0 ([#2063](https://github.com/googleapis/java-bigquerystorage/issues/2063)) ([965de7b](https://github.com/googleapis/java-bigquerystorage/commit/965de7bf78884cca30e6e6d672b74d734bda840d))

## [2.34.1](https://github.com/googleapis/java-bigquerystorage/compare/v2.34.0...v2.34.1) (2023-03-21)


Expand Down
4 changes: 2 additions & 2 deletions README.md
Expand Up @@ -19,7 +19,7 @@ If you are using Maven with [BOM][libraries-bom], add this to your pom.xml file:
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>libraries-bom</artifactId>
<version>26.10.0</version>
<version>26.11.0</version>
<type>pom</type>
<scope>import</scope>
</dependency>
Expand Down Expand Up @@ -49,7 +49,7 @@ If you are using Maven without BOM, add this to your dependencies:
If you are using Gradle 5.x or later, add this to your dependencies:

```Groovy
implementation platform('com.google.cloud:libraries-bom:26.10.0')
implementation platform('com.google.cloud:libraries-bom:26.11.0')
implementation 'com.google.cloud:google-cloud-bigquerystorage'
```
Expand Down
16 changes: 8 additions & 8 deletions google-cloud-bigquerystorage-bom/pom.xml
Expand Up @@ -3,7 +3,7 @@
<modelVersion>4.0.0</modelVersion>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-bigquerystorage-bom</artifactId>
<version>2.34.1</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
<version>2.34.3-SNAPSHOT</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
<packaging>pom</packaging>
<parent>
<groupId>com.google.cloud</groupId>
Expand Down Expand Up @@ -52,37 +52,37 @@
<dependency>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-bigquerystorage</artifactId>
<version>2.34.1</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
<version>2.34.3-SNAPSHOT</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
</dependency>
<dependency>
<groupId>com.google.api.grpc</groupId>
<artifactId>grpc-google-cloud-bigquerystorage-v1beta1</artifactId>
<version>0.158.1</version><!-- {x-version-update:grpc-google-cloud-bigquerystorage-v1beta1:current} -->
<version>0.158.3-SNAPSHOT</version><!-- {x-version-update:grpc-google-cloud-bigquerystorage-v1beta1:current} -->
</dependency>
<dependency>
<groupId>com.google.api.grpc</groupId>
<artifactId>grpc-google-cloud-bigquerystorage-v1beta2</artifactId>
<version>0.158.1</version><!-- {x-version-update:grpc-google-cloud-bigquerystorage-v1beta2:current} -->
<version>0.158.3-SNAPSHOT</version><!-- {x-version-update:grpc-google-cloud-bigquerystorage-v1beta2:current} -->
</dependency>
<dependency>
<groupId>com.google.api.grpc</groupId>
<artifactId>grpc-google-cloud-bigquerystorage-v1</artifactId>
<version>2.34.1</version><!-- {x-version-update:grpc-google-cloud-bigquerystorage-v1:current} -->
<version>2.34.3-SNAPSHOT</version><!-- {x-version-update:grpc-google-cloud-bigquerystorage-v1:current} -->
</dependency>
<dependency>
<groupId>com.google.api.grpc</groupId>
<artifactId>proto-google-cloud-bigquerystorage-v1beta1</artifactId>
<version>0.158.1</version><!-- {x-version-update:proto-google-cloud-bigquerystorage-v1beta1:current} -->
<version>0.158.3-SNAPSHOT</version><!-- {x-version-update:proto-google-cloud-bigquerystorage-v1beta1:current} -->
</dependency>
<dependency>
<groupId>com.google.api.grpc</groupId>
<artifactId>proto-google-cloud-bigquerystorage-v1beta2</artifactId>
<version>0.158.1</version><!-- {x-version-update:proto-google-cloud-bigquerystorage-v1beta2:current} -->
<version>0.158.3-SNAPSHOT</version><!-- {x-version-update:proto-google-cloud-bigquerystorage-v1beta2:current} -->
</dependency>
<dependency>
<groupId>com.google.api.grpc</groupId>
<artifactId>proto-google-cloud-bigquerystorage-v1</artifactId>
<version>2.34.1</version><!-- {x-version-update:proto-google-cloud-bigquerystorage-v1:current} -->
<version>2.34.3-SNAPSHOT</version><!-- {x-version-update:proto-google-cloud-bigquerystorage-v1:current} -->
</dependency>
</dependencies>
</dependencyManagement>
Expand Down
4 changes: 2 additions & 2 deletions google-cloud-bigquerystorage/pom.xml
Expand Up @@ -3,15 +3,15 @@
<modelVersion>4.0.0</modelVersion>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-bigquerystorage</artifactId>
<version>2.34.1</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
<version>2.34.3-SNAPSHOT</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
<packaging>jar</packaging>
<name>BigQuery Storage</name>
<url>https://github.com/googleapis/java-bigquerystorage</url>
<description>BigQuery Storage</description>
<parent>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-bigquerystorage-parent</artifactId>
<version>2.34.1</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
<version>2.34.3-SNAPSHOT</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
</parent>
<properties>
<site.installationModule>google-cloud-bigquerystorage</site.installationModule>
Expand Down
4 changes: 2 additions & 2 deletions grpc-google-cloud-bigquerystorage-v1/pom.xml
Expand Up @@ -4,13 +4,13 @@
<modelVersion>4.0.0</modelVersion>
<groupId>com.google.api.grpc</groupId>
<artifactId>grpc-google-cloud-bigquerystorage-v1</artifactId>
<version>2.34.1</version><!-- {x-version-update:grpc-google-cloud-bigquerystorage-v1:current} -->
<version>2.34.3-SNAPSHOT</version><!-- {x-version-update:grpc-google-cloud-bigquerystorage-v1:current} -->
<name>grpc-google-cloud-bigquerystorage-v1</name>
<description>GRPC library for grpc-google-cloud-bigquerystorage-v1</description>
<parent>
<groupId>com.google.cloud</groupId>
<artifactId>google-cloud-bigquerystorage-parent</artifactId>
<version>2.34.1</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
<version>2.34.3-SNAPSHOT</version><!-- {x-version-update:google-cloud-bigquerystorage:current} -->
</parent>
<dependencies>
<dependency>
Expand Down
Expand Up @@ -225,7 +225,7 @@ public BigQueryReadFutureStub newStub(
* The Read API can be used to read data from BigQuery.
* </pre>
*/
public abstract static class BigQueryReadImplBase implements io.grpc.BindableService {
public interface AsyncService {

/**
*
Expand All @@ -249,7 +249,7 @@ public abstract static class BigQueryReadImplBase implements io.grpc.BindableSer
* not require manual clean-up by the caller.
* </pre>
*/
public void createReadSession(
default void createReadSession(
com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.ReadSession>
responseObserver) {
Expand All @@ -269,7 +269,7 @@ public void createReadSession(
* state of the stream.
* </pre>
*/
public void readRows(
default void readRows(
com.google.cloud.bigquery.storage.v1.ReadRowsRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.ReadRowsResponse>
responseObserver) {
Expand All @@ -293,44 +293,34 @@ public void readRows(
* completion.
* </pre>
*/
public void splitReadStream(
default void splitReadStream(
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>
responseObserver) {
io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(
getSplitReadStreamMethod(), responseObserver);
}
}

/**
* Base class for the server implementation of the service BigQueryRead.
*
* <pre>
* BigQuery Read API.
* The Read API can be used to read data from BigQuery.
* </pre>
*/
public abstract static class BigQueryReadImplBase
implements io.grpc.BindableService, AsyncService {

@java.lang.Override
public final io.grpc.ServerServiceDefinition bindService() {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateReadSessionMethod(),
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(),
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(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest,
com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>(
this, METHODID_SPLIT_READ_STREAM)))
.build();
return BigQueryReadGrpc.bindService(this);
}
}

/**
*
* A stub to allow clients to do asynchronous rpc calls to service BigQueryRead.
*
* <pre>
* BigQuery Read API.
Expand Down Expand Up @@ -429,7 +419,7 @@ public void splitReadStream(
}

/**
*
* A stub to allow clients to do synchronous rpc calls to service BigQueryRead.
*
* <pre>
* BigQuery Read API.
Expand Down Expand Up @@ -519,7 +509,7 @@ public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStr
}

/**
*
* A stub to allow clients to do ListenableFuture-style rpc calls to service BigQueryRead.
*
* <pre>
* BigQuery Read API.
Expand Down Expand Up @@ -601,10 +591,10 @@ private static final class MethodHandlers<Req, Resp>
io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>,
io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>,
io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> {
private final BigQueryReadImplBase serviceImpl;
private final AsyncService serviceImpl;
private final int methodId;

MethodHandlers(BigQueryReadImplBase serviceImpl, int methodId) {
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
Expand Down Expand Up @@ -648,6 +638,32 @@ public io.grpc.stub.StreamObserver<Req> invoke(
}
}

public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateReadSessionMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest,
com.google.cloud.bigquery.storage.v1.ReadSession>(
service, METHODID_CREATE_READ_SESSION)))
.addMethod(
getReadRowsMethod(),
io.grpc.stub.ServerCalls.asyncServerStreamingCall(
new MethodHandlers<
com.google.cloud.bigquery.storage.v1.ReadRowsRequest,
com.google.cloud.bigquery.storage.v1.ReadRowsResponse>(
service, METHODID_READ_ROWS)))
.addMethod(
getSplitReadStreamMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest,
com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>(
service, METHODID_SPLIT_READ_STREAM)))
.build();
}

private abstract static class BigQueryReadBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
Expand Down

0 comments on commit 9b9e420

Please sign in to comment.