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

Jump to bottom

feat: re-generated to pick up changes from googleapis. #982

Merged
merged 3 commits into from Apr 6, 2021
Merged

feat: re-generated to pick up changes from googleapis. #982

Show file tree
Hide file tree
Changes from 2 commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
c56f2c7
feat: updates for v1beta2 storage API - Updated comments on BatchComm…
yoshi-automation Apr 5, 2021
354db4f
feat: deprecate bigquery storage v1alpha2 API
yoshi-automation Apr 5, 2021
806bcd6
chore: update clirr-ignored-differences.xml for v1beta2 proto module
stephaniewang526 Apr 6, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
44 changes: 32 additions & 12 deletions ...storage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteClient.java
View file
Open in desktop
Expand Up @@ -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:
*
Expand Down Expand Up @@ -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:
*
Expand Down Expand Up @@ -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:
*
Expand All @@ -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:
*
Expand Down Expand Up @@ -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:
*
Expand All @@ -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:
*
Expand All @@ -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:
*
Expand All @@ -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:
*
Expand Down Expand Up @@ -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:
*
Expand Down Expand Up @@ -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:
*
Expand All @@ -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:
*
Expand Down Expand Up @@ -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:
*
Expand Down
37 changes: 33 additions & 4 deletions ...-v1alpha2/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/BigQueryWriteGrpc.java
View file
Open in desktop
Expand Up @@ -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() {}
Expand Down Expand Up @@ -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(
Expand Down Expand Up @@ -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(
Expand Down Expand Up @@ -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(
Expand Down Expand Up @@ -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) {
Expand All @@ -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(
Expand Down Expand Up @@ -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(
Expand Down Expand Up @@ -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(
Expand All @@ -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) {
Expand All @@ -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(
Expand All @@ -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
Expand Down Expand Up @@ -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(
Expand All @@ -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) {
Expand All @@ -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<
Expand Down Expand Up @@ -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<
Expand Down Expand Up @@ -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<
Expand Down