Skip to content

Commit

Permalink
chore: Undo removal of --include_source_info from .bazelrc (#694)
Browse files Browse the repository at this point in the history 
Committer: @miraleung
PiperOrigin-RevId: 345067549

Source-Author: Google APIs <noreply@google.com>
Source-Date: Tue Dec 1 11:49:14 2020 -0800
Source-Repo: googleapis/googleapis
Source-Sha: 8cfc6c874574b649b4524a4ef6a0651533325a84
Source-Link: googleapis/googleapis@8cfc6c8
  • Loading branch information
@yoshi-automation
yoshi-automation committed Dec 2, 2020
1 parent 5bb7267 commit 725ba03
Show file tree
Hide file tree
Showing 6 changed files with 1,349 additions and 119 deletions.
248 changes: 232 additions & 16 deletions ...gquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/BigQueryReadGrpc.java
View file
Expand Up @@ -25,7 +25,14 @@
import static io.grpc.stub.ServerCalls.asyncUnaryCall;
import static io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall;

/** */
/**
*
*
* <pre>
* BigQuery Read API.
* The Read API can be used to read data from BigQuery.
* </pre>
*/
@javax.annotation.Generated(
value = "by gRPC proto compiler",
comments = "Source: google/cloud/bigquery/storage/v1/storage.proto")
Expand Down Expand Up @@ -217,26 +224,81 @@ public BigQueryReadFutureStub newStub(
return BigQueryReadFutureStub.newStub(factory, channel);
}

/** */
/**
*
*
* <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 {

/** */
/**
*
*
* <pre>
* Creates a new read session. A read session divides the contents of a
* BigQuery table into one or more streams, which can then be used to read
* data from the table. The read session also specifies properties of the
* data to be read, such as a list of columns or a push-down filter describing
* the rows to be returned.
* A particular row can be read by at most one stream. When the caller has
* reached the end of each stream in the session, then all the data in the
* table has been read.
* Data is assigned to each stream such that roughly the same number of
* rows can be read from each stream. Because the server-side unit for
* assigning data is collections of rows, the API does not guarantee that
* each stream will return the same number or rows. Additionally, the
* limits are enforced based on the number of pre-filtered rows, so some
* filters can lead to lopsided assignments.
* Read sessions automatically expire 24 hours after they are created and do
* not require manual clean-up by the caller.
* </pre>
*/
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);
}

/** */
/**
*
*
* <pre>
* Reads rows from the stream in the format prescribed by the ReadSession.
* Each response contains one or more table rows, up to a maximum of 100 MiB
* per response; read requests which attempt to read individual rows larger
* than 100 MiB will fail.
* Each request also returns a set of stream statistics reflecting the current
* state of the stream.
* </pre>
*/
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);
}

/** */
/**
*
*
* <pre>
* Splits a given `ReadStream` into two `ReadStream` objects. These
* `ReadStream` objects are referred to as the primary and the residual
* streams of the split. The original `ReadStream` can still be read from in
* the same manner as before. Both of the returned `ReadStream` objects can
* also be read from, and the rows returned by both child streams will be
* the same as the rows read from the original stream.
* Moreover, the two child streams will be allocated back-to-back in the
* original `ReadStream`. Concretely, it is guaranteed that for streams
* original, primary, and residual, that original[0-j] = primary[0-j] and
* original[j-n] = residual[0-m] once the streams have been read to
* completion.
* </pre>
*/
public void splitReadStream(
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>
Expand Down Expand Up @@ -272,7 +334,14 @@ public final io.grpc.ServerServiceDefinition bindService() {
}
}

/** */
/**
*
*
* <pre>
* BigQuery Read API.
* The Read API can be used to read data from BigQuery.
* </pre>
*/
public static final class BigQueryReadStub
extends io.grpc.stub.AbstractAsyncStub<BigQueryReadStub> {
private BigQueryReadStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
Expand All @@ -284,7 +353,28 @@ protected BigQueryReadStub build(io.grpc.Channel channel, io.grpc.CallOptions ca
return new BigQueryReadStub(channel, callOptions);
}

/** */
/**
*
*
* <pre>
* Creates a new read session. A read session divides the contents of a
* BigQuery table into one or more streams, which can then be used to read
* data from the table. The read session also specifies properties of the
* data to be read, such as a list of columns or a push-down filter describing
* the rows to be returned.
* A particular row can be read by at most one stream. When the caller has
* reached the end of each stream in the session, then all the data in the
* table has been read.
* Data is assigned to each stream such that roughly the same number of
* rows can be read from each stream. Because the server-side unit for
* assigning data is collections of rows, the API does not guarantee that
* each stream will return the same number or rows. Additionally, the
* limits are enforced based on the number of pre-filtered rows, so some
* filters can lead to lopsided assignments.
* Read sessions automatically expire 24 hours after they are created and do
* not require manual clean-up by the caller.
* </pre>
*/
public void createReadSession(
com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.ReadSession>
Expand All @@ -295,7 +385,18 @@ public void createReadSession(
responseObserver);
}

/** */
/**
*
*
* <pre>
* Reads rows from the stream in the format prescribed by the ReadSession.
* Each response contains one or more table rows, up to a maximum of 100 MiB
* per response; read requests which attempt to read individual rows larger
* than 100 MiB will fail.
* Each request also returns a set of stream statistics reflecting the current
* state of the stream.
* </pre>
*/
public void readRows(
com.google.cloud.bigquery.storage.v1.ReadRowsRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.ReadRowsResponse>
Expand All @@ -304,7 +405,23 @@ public void readRows(
getChannel().newCall(getReadRowsMethod(), getCallOptions()), request, responseObserver);
}

/** */
/**
*
*
* <pre>
* Splits a given `ReadStream` into two `ReadStream` objects. These
* `ReadStream` objects are referred to as the primary and the residual
* streams of the split. The original `ReadStream` can still be read from in
* the same manner as before. Both of the returned `ReadStream` objects can
* also be read from, and the rows returned by both child streams will be
* the same as the rows read from the original stream.
* Moreover, the two child streams will be allocated back-to-back in the
* original `ReadStream`. Concretely, it is guaranteed that for streams
* original, primary, and residual, that original[0-j] = primary[0-j] and
* original[j-n] = residual[0-m] once the streams have been read to
* completion.
* </pre>
*/
public void splitReadStream(
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request,
io.grpc.stub.StreamObserver<com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>
Expand All @@ -316,7 +433,14 @@ public void splitReadStream(
}
}

/** */
/**
*
*
* <pre>
* BigQuery Read API.
* The Read API can be used to read data from BigQuery.
* </pre>
*/
public static final class BigQueryReadBlockingStub
extends io.grpc.stub.AbstractBlockingStub<BigQueryReadBlockingStub> {
private BigQueryReadBlockingStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
Expand All @@ -329,28 +453,83 @@ protected BigQueryReadBlockingStub build(
return new BigQueryReadBlockingStub(channel, callOptions);
}

/** */
/**
*
*
* <pre>
* Creates a new read session. A read session divides the contents of a
* BigQuery table into one or more streams, which can then be used to read
* data from the table. The read session also specifies properties of the
* data to be read, such as a list of columns or a push-down filter describing
* the rows to be returned.
* A particular row can be read by at most one stream. When the caller has
* reached the end of each stream in the session, then all the data in the
* table has been read.
* Data is assigned to each stream such that roughly the same number of
* rows can be read from each stream. Because the server-side unit for
* assigning data is collections of rows, the API does not guarantee that
* each stream will return the same number or rows. Additionally, the
* limits are enforced based on the number of pre-filtered rows, so some
* filters can lead to lopsided assignments.
* Read sessions automatically expire 24 hours after they are created and do
* not require manual clean-up by the caller.
* </pre>
*/
public com.google.cloud.bigquery.storage.v1.ReadSession createReadSession(
com.google.cloud.bigquery.storage.v1.CreateReadSessionRequest request) {
return blockingUnaryCall(
getChannel(), getCreateReadSessionMethod(), getCallOptions(), request);
}

/** */
/**
*
*
* <pre>
* Reads rows from the stream in the format prescribed by the ReadSession.
* Each response contains one or more table rows, up to a maximum of 100 MiB
* per response; read requests which attempt to read individual rows larger
* than 100 MiB will fail.
* Each request also returns a set of stream statistics reflecting the current
* state of the stream.
* </pre>
*/
public java.util.Iterator<com.google.cloud.bigquery.storage.v1.ReadRowsResponse> readRows(
com.google.cloud.bigquery.storage.v1.ReadRowsRequest request) {
return blockingServerStreamingCall(
getChannel(), getReadRowsMethod(), getCallOptions(), request);
}

/** */
/**
*
*
* <pre>
* Splits a given `ReadStream` into two `ReadStream` objects. These
* `ReadStream` objects are referred to as the primary and the residual
* streams of the split. The original `ReadStream` can still be read from in
* the same manner as before. Both of the returned `ReadStream` objects can
* also be read from, and the rows returned by both child streams will be
* the same as the rows read from the original stream.
* Moreover, the two child streams will be allocated back-to-back in the
* original `ReadStream`. Concretely, it is guaranteed that for streams
* original, primary, and residual, that original[0-j] = primary[0-j] and
* original[j-n] = residual[0-m] once the streams have been read to
* completion.
* </pre>
*/
public com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse splitReadStream(
com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) {
return blockingUnaryCall(getChannel(), getSplitReadStreamMethod(), getCallOptions(), request);
}
}

/** */
/**
*
*
* <pre>
* BigQuery Read API.
* The Read API can be used to read data from BigQuery.
* </pre>
*/
public static final class BigQueryReadFutureStub
extends io.grpc.stub.AbstractFutureStub<BigQueryReadFutureStub> {
private BigQueryReadFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
Expand All @@ -363,15 +542,52 @@ protected BigQueryReadFutureStub build(
return new BigQueryReadFutureStub(channel, callOptions);
}

/** */
/**
*
*
* <pre>
* Creates a new read session. A read session divides the contents of a
* BigQuery table into one or more streams, which can then be used to read
* data from the table. The read session also specifies properties of the
* data to be read, such as a list of columns or a push-down filter describing
* the rows to be returned.
* A particular row can be read by at most one stream. When the caller has
* reached the end of each stream in the session, then all the data in the
* table has been read.
* Data is assigned to each stream such that roughly the same number of
* rows can be read from each stream. Because the server-side unit for
* assigning data is collections of rows, the API does not guarantee that
* each stream will return the same number or rows. Additionally, the
* limits are enforced based on the number of pre-filtered rows, so some
* filters can lead to lopsided assignments.
* Read sessions automatically expire 24 hours after they are created and do
* not require manual clean-up by the caller.
* </pre>
*/
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(
getChannel().newCall(getCreateReadSessionMethod(), getCallOptions()), request);
}

/** */
/**
*
*
* <pre>
* Splits a given `ReadStream` into two `ReadStream` objects. These
* `ReadStream` objects are referred to as the primary and the residual
* streams of the split. The original `ReadStream` can still be read from in
* the same manner as before. Both of the returned `ReadStream` objects can
* also be read from, and the rows returned by both child streams will be
* the same as the rows read from the original stream.
* Moreover, the two child streams will be allocated back-to-back in the
* original `ReadStream`. Concretely, it is guaranteed that for streams
* original, primary, and residual, that original[0-j] = primary[0-j] and
* original[j-n] = residual[0-m] once the streams have been read to
* completion.
* </pre>
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.storage.v1.SplitReadStreamResponse>
splitReadStream(com.google.cloud.bigquery.storage.v1.SplitReadStreamRequest request) {
Expand Down

0 comments on commit 725ba03

Please sign in to comment.