Skip to content
Permalink
Browse files
feat: re-generated to pick up changes from googleapis. (#982)
This PR was generated using Autosynth. 🌈

Synth log will be available here:
https://source.cloud.google.com/results/invocations/aa13b61d-ab9b-4c81-9ce0-4b1e2b9fff22/targets

- [ ] To automatically regenerate this PR, check this box. (May take up to 24 hours.)

PiperOrigin-RevId: 366823379
Source-Link: googleapis/googleapis@1a7d764
PiperOrigin-RevId: 366811078
Source-Link: googleapis/googleapis@b1614aa
  • Loading branch information
yoshi-automation committed Apr 6, 2021
1 parent 5c8c4e7 commit 17bfbd8dffd854356ea503adf3a6e065f1e1a4ee
Showing with 1,916 additions and 582 deletions.
  1. +32 −12 ...bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClient.java
  2. +33 −4 ...ystorage-v1alpha2/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteGrpc.java
  3. +238 −40 ...ud-bigquerystorage-v1alpha2/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/Storage.java
  4. +30 −15 ...oud-bigquerystorage-v1alpha2/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/Stream.java
  5. +4 −4 ...loud-bigquerystorage-v1alpha2/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/Table.java
  6. +1 −1 ...oud-bigquerystorage-v1alpha2/src/main/proto/google/cloud/bigquery/storage/v1alpha2/protobuf.proto
  7. +25 −4 ...loud-bigquerystorage-v1alpha2/src/main/proto/google/cloud/bigquery/storage/v1alpha2/storage.proto
  8. +3 −2 ...cloud-bigquerystorage-v1alpha2/src/main/proto/google/cloud/bigquery/storage/v1alpha2/stream.proto
  9. +3 −3 ...-cloud-bigquerystorage-v1alpha2/src/main/proto/google/cloud/bigquery/storage/v1alpha2/table.proto
  10. +3 −3 proto-google-cloud-bigquerystorage-v1beta2/clirr-ignored-differences.xml
  11. +21 −21 ...erystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/AppendRowsRequest.java
  12. +6 −6 ...e-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/AppendRowsRequestOrBuilder.java
  13. +194 −182 ...rystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/AppendRowsResponse.java
  14. +48 −45 ...-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/AppendRowsResponseOrBuilder.java
  15. +14 −14 ...beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BatchCommitWriteStreamsRequest.java
  16. +4 −4 .../main/java/com/google/cloud/bigquery/storage/v1beta2/BatchCommitWriteStreamsRequestOrBuilder.java
  17. +93 −12 ...eta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/BatchCommitWriteStreamsResponse.java
  18. +21 −3 ...main/java/com/google/cloud/bigquery/storage/v1beta2/BatchCommitWriteStreamsResponseOrBuilder.java
  19. +2 −18 ...ud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ProtoRows.java
  20. +2 −2 ...-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ProtoSchema.java
  21. +742 −0 ...uerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsResponse.java
  22. +84 −0 ...ge-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsResponseOrBuilder.java
  23. +9 −0 ...-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSession.java
  24. +30 −6 ...bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StorageError.java
  25. +134 −121 ...bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StorageProto.java
  26. +44 −0 ...uerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/TableFieldSchema.java
  27. +9 −8 ...d-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/TableProto.java
  28. +1 −1 ...le-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/arrow.proto
  29. +1 −1 ...gle-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/avro.proto
  30. +2 −3 ...cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/protobuf.proto
  31. +64 −36 ...-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/storage.proto
  32. +3 −1 ...e-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/stream.proto
  33. +7 −1 ...le-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/table.proto
  34. +9 −9 synth.metadata
@@ -145,7 +145,11 @@ public BigQueryWriteStub getStub() {

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Creates a write stream to the given table.
* Creates a write stream to the given table. Additionally, every table has a special COMMITTED
* stream named '_default' to which data can be written. This stream doesn't need to be created
* using CreateWriteStream. It is a stream that can be used simultaneously by any number of
* clients. Data written to this stream is considered committed as soon as an acknowledgement is
* received.
*
* <p>Sample code:
*
@@ -174,7 +178,11 @@ public final Stream.WriteStream createWriteStream(

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Creates a write stream to the given table.
* Creates a write stream to the given table. Additionally, every table has a special COMMITTED
* stream named '_default' to which data can be written. This stream doesn't need to be created
* using CreateWriteStream. It is a stream that can be used simultaneously by any number of
* clients. Data written to this stream is considered committed as soon as an acknowledgement is
* received.
*
* <p>Sample code:
*
@@ -202,7 +210,11 @@ public final Stream.WriteStream createWriteStream(String parent, Stream.WriteStr

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Creates a write stream to the given table.
* Creates a write stream to the given table. Additionally, every table has a special COMMITTED
* stream named '_default' to which data can be written. This stream doesn't need to be created
* using CreateWriteStream. It is a stream that can be used simultaneously by any number of
* clients. Data written to this stream is considered committed as soon as an acknowledgement is
* received.
*
* <p>Sample code:
*
@@ -225,7 +237,11 @@ public final Stream.WriteStream createWriteStream(Storage.CreateWriteStreamReque

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Creates a write stream to the given table.
* Creates a write stream to the given table. Additionally, every table has a special COMMITTED
* stream named '_default' to which data can be written. This stream doesn't need to be created
* using CreateWriteStream. It is a stream that can be used simultaneously by any number of
* clients. Data written to this stream is considered committed as soon as an acknowledgement is
* received.
*
* <p>Sample code:
*
@@ -390,7 +406,8 @@ public final Stream.WriteStream getWriteStream(Storage.GetWriteStreamRequest req

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Finalize a write stream so that no new data can be appended to the stream.
* Finalize a write stream so that no new data can be appended to the stream. Finalize is not
* supported on the '_default' stream.
*
* <p>Sample code:
*
@@ -415,7 +432,8 @@ public final Storage.FinalizeWriteStreamResponse finalizeWriteStream(WriteStream

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Finalize a write stream so that no new data can be appended to the stream.
* Finalize a write stream so that no new data can be appended to the stream. Finalize is not
* supported on the '_default' stream.
*
* <p>Sample code:
*
@@ -438,7 +456,8 @@ public final Storage.FinalizeWriteStreamResponse finalizeWriteStream(String name

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Finalize a write stream so that no new data can be appended to the stream.
* Finalize a write stream so that no new data can be appended to the stream. Finalize is not
* supported on the '_default' stream.
*
* <p>Sample code:
*
@@ -464,7 +483,8 @@ public final Storage.FinalizeWriteStreamResponse finalizeWriteStream(

// AUTO-GENERATED DOCUMENTATION AND METHOD.
/**
* Finalize a write stream so that no new data can be appended to the stream.
* Finalize a write stream so that no new data can be appended to the stream. Finalize is not
* supported on the '_default' stream.
*
* <p>Sample code:
*
@@ -603,7 +623,7 @@ public final Storage.BatchCommitWriteStreamsResponse batchCommitWriteStreams(
* Flushes rows to a BUFFERED stream. If users are appending rows to BUFFERED stream, flush
* operation is required in order for the rows to become available for reading. A Flush operation
* flushes up to any previously flushed offset in a BUFFERED stream, to the offset specified in
* the request.
* the request. Flush is not supported on the _default stream, since it is not BUFFERED.
*
* <p>Sample code:
*
@@ -631,7 +651,7 @@ public final Storage.FlushRowsResponse flushRows(WriteStreamName writeStream) {
* Flushes rows to a BUFFERED stream. If users are appending rows to BUFFERED stream, flush
* operation is required in order for the rows to become available for reading. A Flush operation
* flushes up to any previously flushed offset in a BUFFERED stream, to the offset specified in
* the request.
* the request. Flush is not supported on the _default stream, since it is not BUFFERED.
*
* <p>Sample code:
*
@@ -657,7 +677,7 @@ public final Storage.FlushRowsResponse flushRows(String writeStream) {
* Flushes rows to a BUFFERED stream. If users are appending rows to BUFFERED stream, flush
* operation is required in order for the rows to become available for reading. A Flush operation
* flushes up to any previously flushed offset in a BUFFERED stream, to the offset specified in
* the request.
* the request. Flush is not supported on the _default stream, since it is not BUFFERED.
*
* <p>Sample code:
*
@@ -685,7 +705,7 @@ public final Storage.FlushRowsResponse flushRows(Storage.FlushRowsRequest reques
* Flushes rows to a BUFFERED stream. If users are appending rows to BUFFERED stream, flush
* operation is required in order for the rows to become available for reading. A Flush operation
* flushes up to any previously flushed offset in a BUFFERED stream, to the offset specified in
* the request.
* the request. Flush is not supported on the _default stream, since it is not BUFFERED.
*
* <p>Sample code:
*
@@ -28,6 +28,7 @@
@javax.annotation.Generated(
value = "by gRPC proto compiler",
comments = "Source: google/cloud/bigquery/storage/v1alpha2/storage.proto")
@java.lang.Deprecated
public final class BigQueryWriteGrpc {

private BigQueryWriteGrpc() {}
@@ -378,13 +379,19 @@ public BigQueryWriteFutureStub newStub(
* The Write API can be used to write data to BigQuery.
* </pre>
*/
@java.lang.Deprecated
public abstract static class BigQueryWriteImplBase implements io.grpc.BindableService {

/**
*
*
* <pre>
* Creates a write stream to the given table.
* Additionally, every table has a special COMMITTED stream named '_default'
* to which data can be written. This stream doesn't need to be created using
* CreateWriteStream. It is a stream that can be used simultaneously by any
* number of clients. Data written to this stream is considered committed as
* soon as an acknowledgement is received.
* </pre>
*/
public void createWriteStream(
@@ -447,7 +454,7 @@ public void getWriteStream(
*
* <pre>
* Finalize a write stream so that no new data can be appended to the
* stream.
* stream. Finalize is not supported on the '_default' stream.
* </pre>
*/
public void finalizeWriteStream(
@@ -488,6 +495,7 @@ public void batchCommitWriteStreams(
* required in order for the rows to become available for reading. A
* Flush operation flushes up to any previously flushed offset in a BUFFERED
* stream, to the offset specified in the request.
* Flush is not supported on the _default stream, since it is not BUFFERED.
* </pre>
*/
public void flushRows(
@@ -557,6 +565,7 @@ public final io.grpc.ServerServiceDefinition bindService() {
* The Write API can be used to write data to BigQuery.
* </pre>
*/
@java.lang.Deprecated
public static final class BigQueryWriteStub
extends io.grpc.stub.AbstractAsyncStub<BigQueryWriteStub> {
private BigQueryWriteStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
@@ -573,6 +582,11 @@ protected BigQueryWriteStub build(io.grpc.Channel channel, io.grpc.CallOptions c
*
* <pre>
* Creates a write stream to the given table.
* Additionally, every table has a special COMMITTED stream named '_default'
* to which data can be written. This stream doesn't need to be created using
* CreateWriteStream. It is a stream that can be used simultaneously by any
* number of clients. Data written to this stream is considered committed as
* soon as an acknowledgement is received.
* </pre>
*/
public void createWriteStream(
@@ -639,7 +653,7 @@ public void getWriteStream(
*
* <pre>
* Finalize a write stream so that no new data can be appended to the
* stream.
* stream. Finalize is not supported on the '_default' stream.
* </pre>
*/
public void finalizeWriteStream(
@@ -684,6 +698,7 @@ public void batchCommitWriteStreams(
* required in order for the rows to become available for reading. A
* Flush operation flushes up to any previously flushed offset in a BUFFERED
* stream, to the offset specified in the request.
* Flush is not supported on the _default stream, since it is not BUFFERED.
* </pre>
*/
public void flushRows(
@@ -704,6 +719,7 @@ public void flushRows(
* The Write API can be used to write data to BigQuery.
* </pre>
*/
@java.lang.Deprecated
public static final class BigQueryWriteBlockingStub
extends io.grpc.stub.AbstractBlockingStub<BigQueryWriteBlockingStub> {
private BigQueryWriteBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
@@ -721,6 +737,11 @@ protected BigQueryWriteBlockingStub build(
*
* <pre>
* Creates a write stream to the given table.
* Additionally, every table has a special COMMITTED stream named '_default'
* to which data can be written. This stream doesn't need to be created using
* CreateWriteStream. It is a stream that can be used simultaneously by any
* number of clients. Data written to this stream is considered committed as
* soon as an acknowledgement is received.
* </pre>
*/
public com.google.cloud.bigquery.storage.v1alpha2.Stream.WriteStream createWriteStream(
@@ -747,7 +768,7 @@ public com.google.cloud.bigquery.storage.v1alpha2.Stream.WriteStream getWriteStr
*
* <pre>
* Finalize a write stream so that no new data can be appended to the
* stream.
* stream. Finalize is not supported on the '_default' stream.
* </pre>
*/
public com.google.cloud.bigquery.storage.v1alpha2.Storage.FinalizeWriteStreamResponse
@@ -785,6 +806,7 @@ public com.google.cloud.bigquery.storage.v1alpha2.Stream.WriteStream getWriteStr
* required in order for the rows to become available for reading. A
* Flush operation flushes up to any previously flushed offset in a BUFFERED
* stream, to the offset specified in the request.
* Flush is not supported on the _default stream, since it is not BUFFERED.
* </pre>
*/
public com.google.cloud.bigquery.storage.v1alpha2.Storage.FlushRowsResponse flushRows(
@@ -802,6 +824,7 @@ public com.google.cloud.bigquery.storage.v1alpha2.Storage.FlushRowsResponse flus
* The Write API can be used to write data to BigQuery.
* </pre>
*/
@java.lang.Deprecated
public static final class BigQueryWriteFutureStub
extends io.grpc.stub.AbstractFutureStub<BigQueryWriteFutureStub> {
private BigQueryWriteFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
@@ -819,6 +842,11 @@ protected BigQueryWriteFutureStub build(
*
* <pre>
* Creates a write stream to the given table.
* Additionally, every table has a special COMMITTED stream named '_default'
* to which data can be written. This stream doesn't need to be created using
* CreateWriteStream. It is a stream that can be used simultaneously by any
* number of clients. Data written to this stream is considered committed as
* soon as an acknowledgement is received.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<
@@ -849,7 +877,7 @@ protected BigQueryWriteFutureStub build(
*
* <pre>
* Finalize a write stream so that no new data can be appended to the
* stream.
* stream. Finalize is not supported on the '_default' stream.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<
@@ -889,6 +917,7 @@ protected BigQueryWriteFutureStub build(
* required in order for the rows to become available for reading. A
* Flush operation flushes up to any previously flushed offset in a BUFFERED
* stream, to the offset specified in the request.
* Flush is not supported on the _default stream, since it is not BUFFERED.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<

0 comments on commit 17bfbd8

Please sign in to comment.