getParserForType() {
+ return PARSER;
+ }
+
+ @java.lang.Override
+ public com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ getDefaultInstanceForType() {
+ return DEFAULT_INSTANCE;
+ }
+}
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ArrowSerializationOptionsOrBuilder.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ArrowSerializationOptionsOrBuilder.java
new file mode 100644
index 0000000000..133e8b1903
--- /dev/null
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ArrowSerializationOptionsOrBuilder.java
@@ -0,0 +1,52 @@
+/*
+ * Copyright 2020 Google LLC
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * https://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+// Generated by the protocol buffer compiler. DO NOT EDIT!
+// source: google/cloud/bigquery/storage/v1beta2/arrow.proto
+
+package com.google.cloud.bigquery.storage.v1beta2;
+
+public interface ArrowSerializationOptionsOrBuilder
+ extends
+ // @@protoc_insertion_point(interface_extends:google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions)
+ com.google.protobuf.MessageOrBuilder {
+
+ /**
+ *
+ *
+ *
+ * The Arrow IPC format to use.
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Format format = 1;
+ *
+ *
+ * @return The enum numeric value on the wire for format.
+ */
+ int getFormatValue();
+ /**
+ *
+ *
+ *
+ * The Arrow IPC format to use.
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Format format = 1;
+ *
+ *
+ * @return The format.
+ */
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Format getFormat();
+}
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsRequest.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsRequest.java
index fdbb036d09..355851d3f3 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsRequest.java
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsRequest.java
@@ -125,7 +125,9 @@ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @return The readStream.
*/
@@ -147,7 +149,9 @@ public java.lang.String getReadStream() {
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @return The bytes for readStream.
*/
@@ -524,7 +528,9 @@ public Builder mergeFrom(
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @return The readStream.
*/
@@ -546,7 +552,9 @@ public java.lang.String getReadStream() {
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @return The bytes for readStream.
*/
@@ -568,7 +576,9 @@ public com.google.protobuf.ByteString getReadStreamBytes() {
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @param value The readStream to set.
* @return This builder for chaining.
@@ -589,7 +599,9 @@ public Builder setReadStream(java.lang.String value) {
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @return This builder for chaining.
*/
@@ -606,7 +618,9 @@ public Builder clearReadStream() {
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @param value The bytes for readStream to set.
* @return This builder for chaining.
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsRequestOrBuilder.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsRequestOrBuilder.java
index ae2d2dae02..614fa22b13 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsRequestOrBuilder.java
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadRowsRequestOrBuilder.java
@@ -30,7 +30,9 @@ public interface ReadRowsRequestOrBuilder
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @return The readStream.
*/
@@ -42,7 +44,9 @@ public interface ReadRowsRequestOrBuilder
* Required. Stream to read rows from.
*
*
- * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string read_stream = 1 [(.google.api.field_behavior) = REQUIRED, (.google.api.resource_reference) = { ... }
+ *
*
* @return The bytes for readStream.
*/
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSession.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSession.java
index dc38c2148e..2ab53778af 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSession.java
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSession.java
@@ -1109,6 +1109,49 @@ public interface TableReadOptionsOrBuilder
* @return The bytes for rowRestriction.
*/
com.google.protobuf.ByteString getRowRestrictionBytes();
+
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return Whether the arrowSerializationOptions field is set.
+ */
+ boolean hasArrowSerializationOptions();
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return The arrowSerializationOptions.
+ */
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ getArrowSerializationOptions();
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptionsOrBuilder
+ getArrowSerializationOptionsOrBuilder();
}
/**
*
@@ -1179,6 +1222,25 @@ private TableReadOptions(
java.lang.String s = input.readStringRequireUtf8();
rowRestriction_ = s;
+ break;
+ }
+ case 26:
+ {
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Builder
+ subBuilder = null;
+ if (arrowSerializationOptions_ != null) {
+ subBuilder = arrowSerializationOptions_.toBuilder();
+ }
+ arrowSerializationOptions_ =
+ input.readMessage(
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ .parser(),
+ extensionRegistry);
+ if (subBuilder != null) {
+ subBuilder.mergeFrom(arrowSerializationOptions_);
+ arrowSerializationOptions_ = subBuilder.buildPartial();
+ }
+
break;
}
default:
@@ -1352,6 +1414,60 @@ public com.google.protobuf.ByteString getRowRestrictionBytes() {
}
}
+ public static final int ARROW_SERIALIZATION_OPTIONS_FIELD_NUMBER = 3;
+ private com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ arrowSerializationOptions_;
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return Whether the arrowSerializationOptions field is set.
+ */
+ public boolean hasArrowSerializationOptions() {
+ return arrowSerializationOptions_ != null;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return The arrowSerializationOptions.
+ */
+ public com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ getArrowSerializationOptions() {
+ return arrowSerializationOptions_ == null
+ ? com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.getDefaultInstance()
+ : arrowSerializationOptions_;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptionsOrBuilder
+ getArrowSerializationOptionsOrBuilder() {
+ return getArrowSerializationOptions();
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
@@ -1372,6 +1488,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (!getRowRestrictionBytes().isEmpty()) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 2, rowRestriction_);
}
+ if (arrowSerializationOptions_ != null) {
+ output.writeMessage(3, getArrowSerializationOptions());
+ }
unknownFields.writeTo(output);
}
@@ -1392,6 +1511,11 @@ public int getSerializedSize() {
if (!getRowRestrictionBytes().isEmpty()) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(2, rowRestriction_);
}
+ if (arrowSerializationOptions_ != null) {
+ size +=
+ com.google.protobuf.CodedOutputStream.computeMessageSize(
+ 3, getArrowSerializationOptions());
+ }
size += unknownFields.getSerializedSize();
memoizedSize = size;
return size;
@@ -1411,6 +1535,11 @@ public boolean equals(final java.lang.Object obj) {
if (!getSelectedFieldsList().equals(other.getSelectedFieldsList())) return false;
if (!getRowRestriction().equals(other.getRowRestriction())) return false;
+ if (hasArrowSerializationOptions() != other.hasArrowSerializationOptions()) return false;
+ if (hasArrowSerializationOptions()) {
+ if (!getArrowSerializationOptions().equals(other.getArrowSerializationOptions()))
+ return false;
+ }
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
}
@@ -1428,6 +1557,10 @@ public int hashCode() {
}
hash = (37 * hash) + ROW_RESTRICTION_FIELD_NUMBER;
hash = (53 * hash) + getRowRestriction().hashCode();
+ if (hasArrowSerializationOptions()) {
+ hash = (37 * hash) + ARROW_SERIALIZATION_OPTIONS_FIELD_NUMBER;
+ hash = (53 * hash) + getArrowSerializationOptions().hashCode();
+ }
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
@@ -1583,6 +1716,12 @@ public Builder clear() {
bitField0_ = (bitField0_ & ~0x00000001);
rowRestriction_ = "";
+ if (arrowSerializationOptionsBuilder_ == null) {
+ arrowSerializationOptions_ = null;
+ } else {
+ arrowSerializationOptions_ = null;
+ arrowSerializationOptionsBuilder_ = null;
+ }
return this;
}
@@ -1620,6 +1759,11 @@ public com.google.cloud.bigquery.storage.v1beta2.ReadSession.TableReadOptions bu
}
result.selectedFields_ = selectedFields_;
result.rowRestriction_ = rowRestriction_;
+ if (arrowSerializationOptionsBuilder_ == null) {
+ result.arrowSerializationOptions_ = arrowSerializationOptions_;
+ } else {
+ result.arrowSerializationOptions_ = arrowSerializationOptionsBuilder_.build();
+ }
onBuilt();
return result;
}
@@ -1690,6 +1834,9 @@ public Builder mergeFrom(
rowRestriction_ = other.rowRestriction_;
onChanged();
}
+ if (other.hasArrowSerializationOptions()) {
+ mergeArrowSerializationOptions(other.getArrowSerializationOptions());
+ }
this.mergeUnknownFields(other.unknownFields);
onChanged();
return this;
@@ -2058,6 +2205,220 @@ public Builder setRowRestrictionBytes(com.google.protobuf.ByteString value) {
return this;
}
+ private com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ arrowSerializationOptions_;
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions,
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Builder,
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptionsOrBuilder>
+ arrowSerializationOptionsBuilder_;
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return Whether the arrowSerializationOptions field is set.
+ */
+ public boolean hasArrowSerializationOptions() {
+ return arrowSerializationOptionsBuilder_ != null || arrowSerializationOptions_ != null;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ *
+ * @return The arrowSerializationOptions.
+ */
+ public com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ getArrowSerializationOptions() {
+ if (arrowSerializationOptionsBuilder_ == null) {
+ return arrowSerializationOptions_ == null
+ ? com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ .getDefaultInstance()
+ : arrowSerializationOptions_;
+ } else {
+ return arrowSerializationOptionsBuilder_.getMessage();
+ }
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public Builder setArrowSerializationOptions(
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions value) {
+ if (arrowSerializationOptionsBuilder_ == null) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+ arrowSerializationOptions_ = value;
+ onChanged();
+ } else {
+ arrowSerializationOptionsBuilder_.setMessage(value);
+ }
+
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public Builder setArrowSerializationOptions(
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Builder
+ builderForValue) {
+ if (arrowSerializationOptionsBuilder_ == null) {
+ arrowSerializationOptions_ = builderForValue.build();
+ onChanged();
+ } else {
+ arrowSerializationOptionsBuilder_.setMessage(builderForValue.build());
+ }
+
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public Builder mergeArrowSerializationOptions(
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions value) {
+ if (arrowSerializationOptionsBuilder_ == null) {
+ if (arrowSerializationOptions_ != null) {
+ arrowSerializationOptions_ =
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.newBuilder(
+ arrowSerializationOptions_)
+ .mergeFrom(value)
+ .buildPartial();
+ } else {
+ arrowSerializationOptions_ = value;
+ }
+ onChanged();
+ } else {
+ arrowSerializationOptionsBuilder_.mergeFrom(value);
+ }
+
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public Builder clearArrowSerializationOptions() {
+ if (arrowSerializationOptionsBuilder_ == null) {
+ arrowSerializationOptions_ = null;
+ onChanged();
+ } else {
+ arrowSerializationOptions_ = null;
+ arrowSerializationOptionsBuilder_ = null;
+ }
+
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Builder
+ getArrowSerializationOptionsBuilder() {
+
+ onChanged();
+ return getArrowSerializationOptionsFieldBuilder().getBuilder();
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ public com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptionsOrBuilder
+ getArrowSerializationOptionsOrBuilder() {
+ if (arrowSerializationOptionsBuilder_ != null) {
+ return arrowSerializationOptionsBuilder_.getMessageOrBuilder();
+ } else {
+ return arrowSerializationOptions_ == null
+ ? com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions
+ .getDefaultInstance()
+ : arrowSerializationOptions_;
+ }
+ }
+ /**
+ *
+ *
+ *
+ * Optional. Options specific to the Apache Arrow output format.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions arrow_serialization_options = 3 [(.google.api.field_behavior) = OPTIONAL];
+ *
+ */
+ private com.google.protobuf.SingleFieldBuilderV3<
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions,
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Builder,
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptionsOrBuilder>
+ getArrowSerializationOptionsFieldBuilder() {
+ if (arrowSerializationOptionsBuilder_ == null) {
+ arrowSerializationOptionsBuilder_ =
+ new com.google.protobuf.SingleFieldBuilderV3<
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions,
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptions.Builder,
+ com.google.cloud.bigquery.storage.v1beta2.ArrowSerializationOptionsOrBuilder>(
+ getArrowSerializationOptions(), getParentForChildren(), isClean());
+ arrowSerializationOptions_ = null;
+ }
+ return arrowSerializationOptionsBuilder_;
+ }
+
@java.lang.Override
public final Builder setUnknownFields(
final com.google.protobuf.UnknownFieldSet unknownFields) {
@@ -2213,10 +2574,9 @@ public com.google.protobuf.ByteString getNameBytes() {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
* .google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -2231,10 +2591,9 @@ public boolean hasExpireTime() {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
* .google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -2249,10 +2608,9 @@ public com.google.protobuf.Timestamp getExpireTime() {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
* .google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -2268,8 +2626,7 @@ public com.google.protobuf.TimestampOrBuilder getExpireTimeOrBuilder() {
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -2285,8 +2642,7 @@ public int getDataFormatValue() {
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -2418,11 +2774,13 @@ public com.google.cloud.bigquery.storage.v1beta2.ArrowSchemaOrBuilder getArrowSc
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @return The table.
*/
@@ -2441,11 +2799,13 @@ public java.lang.String getTable() {
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @return The bytes for table.
*/
@@ -2467,8 +2827,7 @@ public com.google.protobuf.ByteString getTableBytes() {
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -2484,8 +2843,7 @@ public boolean hasTableModifiers() {
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -2503,8 +2861,7 @@ public com.google.cloud.bigquery.storage.v1beta2.ReadSession.TableModifiers getT
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -3367,10 +3724,9 @@ public Builder setNameBytes(com.google.protobuf.ByteString value) {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3386,10 +3742,9 @@ public boolean hasExpireTime() {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3411,10 +3766,9 @@ public com.google.protobuf.Timestamp getExpireTime() {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3438,10 +3792,9 @@ public Builder setExpireTime(com.google.protobuf.Timestamp value) {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3462,10 +3815,9 @@ public Builder setExpireTime(com.google.protobuf.Timestamp.Builder builderForVal
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3491,10 +3843,9 @@ public Builder mergeExpireTime(com.google.protobuf.Timestamp value) {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3516,10 +3867,9 @@ public Builder clearExpireTime() {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3535,10 +3885,9 @@ public com.google.protobuf.Timestamp.Builder getExpireTimeBuilder() {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3558,10 +3907,9 @@ public com.google.protobuf.TimestampOrBuilder getExpireTimeOrBuilder() {
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
*
@@ -3590,8 +3938,7 @@ public com.google.protobuf.TimestampOrBuilder getExpireTimeOrBuilder() {
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -3607,8 +3954,7 @@ public int getDataFormatValue() {
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -3627,8 +3973,7 @@ public Builder setDataFormatValue(int value) {
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -3649,8 +3994,7 @@ public com.google.cloud.bigquery.storage.v1beta2.DataFormat getDataFormat() {
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -3673,8 +4017,7 @@ public Builder setDataFormat(com.google.cloud.bigquery.storage.v1beta2.DataForma
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -4146,11 +4489,13 @@ public com.google.cloud.bigquery.storage.v1beta2.ArrowSchema.Builder getArrowSch
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @return The table.
*/
@@ -4169,11 +4514,13 @@ public java.lang.String getTable() {
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @return The bytes for table.
*/
@@ -4192,11 +4539,13 @@ public com.google.protobuf.ByteString getTableBytes() {
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @param value The table to set.
* @return This builder for chaining.
@@ -4214,11 +4563,13 @@ public Builder setTable(java.lang.String value) {
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @return This builder for chaining.
*/
@@ -4232,11 +4583,13 @@ public Builder clearTable() {
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @param value The bytes for table to set.
* @return This builder for chaining.
@@ -4262,8 +4615,7 @@ public Builder setTableBytes(com.google.protobuf.ByteString value) {
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -4279,8 +4631,7 @@ public boolean hasTableModifiers() {
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -4304,8 +4655,7 @@ public boolean hasTableModifiers() {
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -4330,8 +4680,7 @@ public Builder setTableModifiers(
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -4354,8 +4703,7 @@ public Builder setTableModifiers(
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -4385,8 +4733,7 @@ public Builder mergeTableModifiers(
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -4408,8 +4755,7 @@ public Builder clearTableModifiers() {
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -4426,8 +4772,7 @@ public Builder clearTableModifiers() {
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -4449,8 +4794,7 @@ public Builder clearTableModifiers() {
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSessionOrBuilder.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSessionOrBuilder.java
index bc65716270..1fce122602 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSessionOrBuilder.java
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/ReadSessionOrBuilder.java
@@ -54,10 +54,9 @@ public interface ReadSessionOrBuilder
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
* .google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -70,10 +69,9 @@ public interface ReadSessionOrBuilder
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
* .google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -86,10 +84,9 @@ public interface ReadSessionOrBuilder
*
*
*
- * Output only. Time at which the session becomes invalid. After this time,
- * subsequent requests to read this Session will return errors. The
- * expire_time is automatically assigned and currently cannot be specified or
- * updated.
+ * Output only. Time at which the session becomes invalid. After this time, subsequent
+ * requests to read this Session will return errors. The expire_time is
+ * automatically assigned and currently cannot be specified or updated.
*
*
* .google.protobuf.Timestamp expire_time = 2 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -101,8 +98,7 @@ public interface ReadSessionOrBuilder
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -116,8 +112,7 @@ public interface ReadSessionOrBuilder
*
*
*
- * Immutable. Data format of the output data. Behavior defaults to Apache
- * Avro.
+ * Immutable. Data format of the output data.
*
*
*
@@ -214,11 +209,13 @@ public interface ReadSessionOrBuilder
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @return The table.
*/
@@ -227,11 +224,13 @@ public interface ReadSessionOrBuilder
*
*
*
- * Table that this ReadSession is reading from, in the form
+ * Immutable. Table that this ReadSession is reading from, in the form
* `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
*
*
- * string table = 6;
+ *
+ * string table = 6 [(.google.api.field_behavior) = IMMUTABLE, (.google.api.resource_reference) = { ... }
+ *
*
* @return The bytes for table.
*/
@@ -241,8 +240,7 @@ public interface ReadSessionOrBuilder
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -256,8 +254,7 @@ public interface ReadSessionOrBuilder
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
@@ -271,8 +268,7 @@ public interface ReadSessionOrBuilder
*
*
*
- * Optional. Any modifiers which are applied when reading from the specified
- * table.
+ * Optional. Any modifiers which are applied when reading from the specified table.
*
*
*
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StorageProto.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StorageProto.java
index 4e8dd74a5a..9c81d6522c 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StorageProto.java
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StorageProto.java
@@ -82,55 +82,56 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
+ "leapis.com/Project\022M\n\014read_session\030\002 \001(\013"
+ "22.google.cloud.bigquery.storage.v1beta2"
+ ".ReadSessionB\003\340A\002\022\030\n\020max_stream_count\030\003 "
- + "\001(\005\";\n\017ReadRowsRequest\022\030\n\013read_stream\030\001 "
- + "\001(\tB\003\340A\002\022\016\n\006offset\030\002 \001(\003\")\n\rThrottleStat"
- + "e\022\030\n\020throttle_percent\030\001 \001(\005\"\234\001\n\013StreamSt"
- + "ats\022M\n\010progress\030\002 \001(\0132;.google.cloud.big"
- + "query.storage.v1beta2.StreamStats.Progre"
- + "ss\032>\n\010Progress\022\031\n\021at_response_start\030\001 \001("
- + "\001\022\027\n\017at_response_end\030\002 \001(\001\"\333\002\n\020ReadRowsR"
- + "esponse\022D\n\tavro_rows\030\003 \001(\0132/.google.clou"
- + "d.bigquery.storage.v1beta2.AvroRowsH\000\022U\n"
- + "\022arrow_record_batch\030\004 \001(\01327.google.cloud"
- + ".bigquery.storage.v1beta2.ArrowRecordBat"
- + "chH\000\022\021\n\trow_count\030\006 \001(\003\022A\n\005stats\030\002 \001(\01322"
- + ".google.cloud.bigquery.storage.v1beta2.S"
- + "treamStats\022L\n\016throttle_state\030\005 \001(\01324.goo"
- + "gle.cloud.bigquery.storage.v1beta2.Throt"
- + "tleStateB\006\n\004rows\"k\n\026SplitReadStreamReque"
- + "st\022?\n\004name\030\001 \001(\tB1\340A\002\372A+\n)bigquerystorag"
- + "e.googleapis.com/ReadStream\022\020\n\010fraction\030"
- + "\002 \001(\001\"\261\001\n\027SplitReadStreamResponse\022I\n\016pri"
- + "mary_stream\030\001 \001(\01321.google.cloud.bigquer"
- + "y.storage.v1beta2.ReadStream\022K\n\020remainde"
- + "r_stream\030\002 \001(\01321.google.cloud.bigquery.s"
- + "torage.v1beta2.ReadStream2\363\006\n\014BigQueryRe"
- + "ad\022\370\001\n\021CreateReadSession\022?.google.cloud."
- + "bigquery.storage.v1beta2.CreateReadSessi"
- + "onRequest\0322.google.cloud.bigquery.storag"
- + "e.v1beta2.ReadSession\"n\202\323\344\223\002A\".google.cloud.bigquery.storage.v1beta"
- + "2.SplitReadStreamResponse\"C\202\323\344\223\002=\022;/v1be"
- + "ta2/{name=projects/*/locations/*/session"
- + "s/*/streams/*}\032\256\001\312A\036bigquerystorage.goog"
- + "leapis.com\322A\211\001https://www.googleapis.com"
- + "/auth/bigquery,https://www.googleapis.co"
- + "m/auth/bigquery.readonly,https://www.goo"
- + "gleapis.com/auth/cloud-platformB\211\001\n)com."
- + "google.cloud.bigquery.storage.v1beta2B\014S"
- + "torageProtoP\001ZLgoogle.golang.org/genprot"
- + "o/googleapis/cloud/bigquery/storage/v1be"
- + "ta2;storageb\006proto3"
+ + "\001(\005\"i\n\017ReadRowsRequest\022F\n\013read_stream\030\001 "
+ + "\001(\tB1\340A\002\372A+\n)bigquerystorage.googleapis."
+ + "com/ReadStream\022\016\n\006offset\030\002 \001(\003\")\n\rThrott"
+ + "leState\022\030\n\020throttle_percent\030\001 \001(\005\"\234\001\n\013St"
+ + "reamStats\022M\n\010progress\030\002 \001(\0132;.google.clo"
+ + "ud.bigquery.storage.v1beta2.StreamStats."
+ + "Progress\032>\n\010Progress\022\031\n\021at_response_star"
+ + "t\030\001 \001(\001\022\027\n\017at_response_end\030\002 \001(\001\"\333\002\n\020Rea"
+ + "dRowsResponse\022D\n\tavro_rows\030\003 \001(\0132/.googl"
+ + "e.cloud.bigquery.storage.v1beta2.AvroRow"
+ + "sH\000\022U\n\022arrow_record_batch\030\004 \001(\01327.google"
+ + ".cloud.bigquery.storage.v1beta2.ArrowRec"
+ + "ordBatchH\000\022\021\n\trow_count\030\006 \001(\003\022A\n\005stats\030\002"
+ + " \001(\01322.google.cloud.bigquery.storage.v1b"
+ + "eta2.StreamStats\022L\n\016throttle_state\030\005 \001(\013"
+ + "24.google.cloud.bigquery.storage.v1beta2"
+ + ".ThrottleStateB\006\n\004rows\"k\n\026SplitReadStrea"
+ + "mRequest\022?\n\004name\030\001 \001(\tB1\340A\002\372A+\n)bigquery"
+ + "storage.googleapis.com/ReadStream\022\020\n\010fra"
+ + "ction\030\002 \001(\001\"\261\001\n\027SplitReadStreamResponse\022"
+ + "I\n\016primary_stream\030\001 \001(\01321.google.cloud.b"
+ + "igquery.storage.v1beta2.ReadStream\022K\n\020re"
+ + "mainder_stream\030\002 \001(\01321.google.cloud.bigq"
+ + "uery.storage.v1beta2.ReadStream2\363\006\n\014BigQ"
+ + "ueryRead\022\370\001\n\021CreateReadSession\022?.google."
+ + "cloud.bigquery.storage.v1beta2.CreateRea"
+ + "dSessionRequest\0322.google.cloud.bigquery."
+ + "storage.v1beta2.ReadSession\"n\202\323\344\223\002A\".google.cloud.bigquery.storage."
+ + "v1beta2.SplitReadStreamResponse\"C\202\323\344\223\002=\022"
+ + ";/v1beta2/{name=projects/*/locations/*/s"
+ + "essions/*/streams/*}\032\256\001\312A\036bigquerystorag"
+ + "e.googleapis.com\322A\211\001https://www.googleap"
+ + "is.com/auth/bigquery,https://www.googlea"
+ + "pis.com/auth/bigquery.readonly,https://w"
+ + "ww.googleapis.com/auth/cloud-platformB\211\001"
+ + "\n)com.google.cloud.bigquery.storage.v1be"
+ + "ta2B\014StorageProtoP\001ZLgoogle.golang.org/g"
+ + "enproto/googleapis/cloud/bigquery/storag"
+ + "e/v1beta2;storageb\006proto3"
};
descriptor =
com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamProto.java b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamProto.java
index c50e3c3cde..49c4975dce 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamProto.java
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/java/com/google/cloud/bigquery/storage/v1beta2/StreamProto.java
@@ -59,7 +59,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
+ "cloud/bigquery/storage/v1beta2/arrow.pro"
+ "to\0320google/cloud/bigquery/storage/v1beta"
+ "2/avro.proto\032\037google/protobuf/timestamp."
- + "proto\"\336\006\n\013ReadSession\022\021\n\004name\030\001 \001(\tB\003\340A\003"
+ + "proto\"\362\007\n\013ReadSession\022\021\n\004name\030\001 \001(\tB\003\340A\003"
+ "\0224\n\013expire_time\030\002 \001(\0132\032.google.protobuf."
+ "TimestampB\003\340A\003\022K\n\013data_format\030\003 \001(\01621.go"
+ "ogle.cloud.bigquery.storage.v1beta2.Data"
@@ -67,29 +67,35 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
+ "e.cloud.bigquery.storage.v1beta2.AvroSch"
+ "emaB\003\340A\003H\000\022O\n\014arrow_schema\030\005 \001(\01322.googl"
+ "e.cloud.bigquery.storage.v1beta2.ArrowSc"
- + "hemaB\003\340A\003H\000\022\r\n\005table\030\006 \001(\t\022_\n\017table_modi"
- + "fiers\030\007 \001(\0132A.google.cloud.bigquery.stor"
- + "age.v1beta2.ReadSession.TableModifiersB\003"
- + "\340A\001\022^\n\014read_options\030\010 \001(\0132C.google.cloud"
- + ".bigquery.storage.v1beta2.ReadSession.Ta"
- + "bleReadOptionsB\003\340A\001\022G\n\007streams\030\n \003(\01321.g"
- + "oogle.cloud.bigquery.storage.v1beta2.Rea"
- + "dStreamB\003\340A\003\032C\n\016TableModifiers\0221\n\rsnapsh"
- + "ot_time\030\001 \001(\0132\032.google.protobuf.Timestam"
- + "p\032D\n\020TableReadOptions\022\027\n\017selected_fields"
- + "\030\001 \003(\t\022\027\n\017row_restriction\030\002 \001(\t:k\352Ah\n*bi"
- + "gquerystorage.googleapis.com/ReadSession"
- + "\022:projects/{project}/locations/{location"
- + "}/sessions/{session}B\010\n\006schema\"\234\001\n\nReadS"
- + "tream\022\021\n\004name\030\001 \001(\tB\003\340A\003:{\352Ax\n)bigquerys"
- + "torage.googleapis.com/ReadStream\022Kprojec"
- + "ts/{project}/locations/{location}/sessio"
- + "ns/{session}/streams/{stream}*>\n\nDataFor"
- + "mat\022\033\n\027DATA_FORMAT_UNSPECIFIED\020\000\022\010\n\004AVRO"
- + "\020\001\022\t\n\005ARROW\020\002B\210\001\n)com.google.cloud.bigqu"
- + "ery.storage.v1beta2B\013StreamProtoP\001ZLgoog"
- + "le.golang.org/genproto/googleapis/cloud/"
- + "bigquery/storage/v1beta2;storageb\006proto3"
+ + "hemaB\003\340A\003H\000\0224\n\005table\030\006 \001(\tB%\340A\005\372A\037\n\035bigq"
+ + "uery.googleapis.com/Table\022_\n\017table_modif"
+ + "iers\030\007 \001(\0132A.google.cloud.bigquery.stora"
+ + "ge.v1beta2.ReadSession.TableModifiersB\003\340"
+ + "A\001\022^\n\014read_options\030\010 \001(\0132C.google.cloud."
+ + "bigquery.storage.v1beta2.ReadSession.Tab"
+ + "leReadOptionsB\003\340A\001\022G\n\007streams\030\n \003(\01321.go"
+ + "ogle.cloud.bigquery.storage.v1beta2.Read"
+ + "StreamB\003\340A\003\032C\n\016TableModifiers\0221\n\rsnapsho"
+ + "t_time\030\001 \001(\0132\032.google.protobuf.Timestamp"
+ + "\032\260\001\n\020TableReadOptions\022\027\n\017selected_fields"
+ + "\030\001 \003(\t\022\027\n\017row_restriction\030\002 \001(\t\022j\n\033arrow"
+ + "_serialization_options\030\003 \001(\0132@.google.cl"
+ + "oud.bigquery.storage.v1beta2.ArrowSerial"
+ + "izationOptionsB\003\340A\001:k\352Ah\n*bigquerystorag"
+ + "e.googleapis.com/ReadSession\022:projects/{"
+ + "project}/locations/{location}/sessions/{"
+ + "session}B\010\n\006schema\"\234\001\n\nReadStream\022\021\n\004nam"
+ + "e\030\001 \001(\tB\003\340A\003:{\352Ax\n)bigquerystorage.googl"
+ + "eapis.com/ReadStream\022Kprojects/{project}"
+ + "/locations/{location}/sessions/{session}"
+ + "/streams/{stream}*>\n\nDataFormat\022\033\n\027DATA_"
+ + "FORMAT_UNSPECIFIED\020\000\022\010\n\004AVRO\020\001\022\t\n\005ARROW\020"
+ + "\002B\340\001\n)com.google.cloud.bigquery.storage."
+ + "v1beta2B\013StreamProtoP\001ZLgoogle.golang.or"
+ + "g/genproto/googleapis/cloud/bigquery/sto"
+ + "rage/v1beta2;storage\352AU\n\035bigquery.google"
+ + "apis.com/Table\0224projects/{project}/datas"
+ + "ets/{dataset}/tables/{table}b\006proto3"
};
descriptor =
com.google.protobuf.Descriptors.FileDescriptor.internalBuildGeneratedFileFrom(
@@ -136,7 +142,7 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
new com.google.protobuf.GeneratedMessageV3.FieldAccessorTable(
internal_static_google_cloud_bigquery_storage_v1beta2_ReadSession_TableReadOptions_descriptor,
new java.lang.String[] {
- "SelectedFields", "RowRestriction",
+ "SelectedFields", "RowRestriction", "ArrowSerializationOptions",
});
internal_static_google_cloud_bigquery_storage_v1beta2_ReadStream_descriptor =
getDescriptor().getMessageTypes().get(1);
@@ -150,6 +156,8 @@ public static com.google.protobuf.Descriptors.FileDescriptor getDescriptor() {
com.google.protobuf.ExtensionRegistry.newInstance();
registry.add(com.google.api.FieldBehaviorProto.fieldBehavior);
registry.add(com.google.api.ResourceProto.resource);
+ registry.add(com.google.api.ResourceProto.resourceDefinition);
+ registry.add(com.google.api.ResourceProto.resourceReference);
com.google.protobuf.Descriptors.FileDescriptor.internalUpdateFileDescriptor(
descriptor, registry);
com.google.api.FieldBehaviorProto.getDescriptor();
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/arrow.proto b/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/arrow.proto
index 0cca110293..ad178dcec4 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/arrow.proto
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/arrow.proto
@@ -38,3 +38,21 @@ message ArrowRecordBatch {
// IPC-serialized Arrow RecordBatch.
bytes serialized_record_batch = 1;
}
+
+// Contains options specific to Arrow Serialization.
+message ArrowSerializationOptions {
+ // The IPC format to use when serializing Arrow streams.
+ enum Format {
+ // If unspecied the IPC format as of 0.15 release will be used.
+ FORMAT_UNSPECIFIED = 0;
+
+ // Use the legacy IPC message format as of Apache Arrow Release 0.14.
+ ARROW_0_14 = 1;
+
+ // Use the message format as of Apache Arrow Release 0.15.
+ ARROW_0_15 = 2;
+ }
+
+ // The Arrow IPC format to use.
+ Format format = 1;
+}
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/storage.proto b/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/storage.proto
index be03525403..373c835253 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/storage.proto
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/storage.proto
@@ -64,8 +64,7 @@ service BigQueryRead {
post: "/v1beta2/{read_session.table=projects/*/datasets/*/tables/*}"
body: "*"
};
- option (google.api.method_signature) =
- "parent,read_session,max_stream_count";
+ option (google.api.method_signature) = "parent,read_session,max_stream_count";
}
// Reads rows from the stream in the format prescribed by the ReadSession.
@@ -94,8 +93,7 @@ service BigQueryRead {
// 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.
- rpc SplitReadStream(SplitReadStreamRequest)
- returns (SplitReadStreamResponse) {
+ rpc SplitReadStream(SplitReadStreamRequest) returns (SplitReadStreamResponse) {
option (google.api.http) = {
get: "/v1beta2/{name=projects/*/locations/*/sessions/*/streams/*}"
};
@@ -130,7 +128,12 @@ message CreateReadSessionRequest {
// Request message for `ReadRows`.
message ReadRowsRequest {
// Required. Stream to read rows from.
- string read_stream = 1 [(google.api.field_behavior) = REQUIRED];
+ string read_stream = 1 [
+ (google.api.field_behavior) = REQUIRED,
+ (google.api.resource_reference) = {
+ type: "bigquerystorage.googleapis.com/ReadStream"
+ }
+ ];
// The offset requested must be less than the last row read from Read.
// Requesting a larger offset is undefined. If not specified, start reading
diff --git a/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/stream.proto b/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/stream.proto
index e5e643b9e2..cad7f95a51 100644
--- a/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/stream.proto
+++ b/proto-google-cloud-bigquerystorage-v1beta2/src/main/proto/google/cloud/bigquery/storage/v1beta2/stream.proto
@@ -27,6 +27,10 @@ option go_package = "google.golang.org/genproto/googleapis/cloud/bigquery/storag
option java_multiple_files = true;
option java_outer_classname = "StreamProto";
option java_package = "com.google.cloud.bigquery.storage.v1beta2";
+option (google.api.resource_definition) = {
+ type: "bigquery.googleapis.com/Table"
+ pattern: "projects/{project}/datasets/{dataset}/tables/{table}"
+};
// Data format for input or output data.
enum DataFormat {
@@ -72,21 +76,21 @@ message ReadSession {
// "st_equals(geo_field, st_geofromtext("POINT(2, 2)"))"
// "numeric_field BETWEEN 1.0 AND 5.0"
string row_restriction = 2;
+
+ // Optional. Options specific to the Apache Arrow output format.
+ ArrowSerializationOptions arrow_serialization_options = 3 [(google.api.field_behavior) = OPTIONAL];
}
// Output only. Unique identifier for the session, in the form
// `projects/{project_id}/locations/{location}/sessions/{session_id}`.
string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
- // Output only. Time at which the session becomes invalid. After this time,
- // subsequent requests to read this Session will return errors. The
- // expire_time is automatically assigned and currently cannot be specified or
- // updated.
- google.protobuf.Timestamp expire_time = 2
- [(google.api.field_behavior) = OUTPUT_ONLY];
+ // Output only. Time at which the session becomes invalid. After this time, subsequent
+ // requests to read this Session will return errors. The expire_time is
+ // automatically assigned and currently cannot be specified or updated.
+ google.protobuf.Timestamp expire_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY];
- // Immutable. Data format of the output data. Behavior defaults to Apache
- // Avro.
+ // Immutable. Data format of the output data.
DataFormat data_format = 3 [(google.api.field_behavior) = IMMUTABLE];
// The schema for the read. If read_options.selected_fields is set, the
@@ -100,12 +104,16 @@ message ReadSession {
ArrowSchema arrow_schema = 5 [(google.api.field_behavior) = OUTPUT_ONLY];
}
- // Table that this ReadSession is reading from, in the form
+ // Immutable. Table that this ReadSession is reading from, in the form
// `projects/{project_id}/datasets/{dataset_id}/tables/{table_id}
- string table = 6;
-
- // Optional. Any modifiers which are applied when reading from the specified
- // table.
+ string table = 6 [
+ (google.api.field_behavior) = IMMUTABLE,
+ (google.api.resource_reference) = {
+ type: "bigquery.googleapis.com/Table"
+ }
+ ];
+
+ // Optional. Any modifiers which are applied when reading from the specified table.
TableModifiers table_modifiers = 7 [(google.api.field_behavior) = OPTIONAL];
// Optional. Read options for this session (e.g. column selection, filters).
diff --git a/synth.metadata b/synth.metadata
index 484ad05ef1..cbf8588862 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -1,6 +1,20 @@
{
- "updateTime": "2020-02-11T10:29:54.654184Z",
+ "updateTime": "2020-02-11T22:40:41.222574Z",
"sources": [
+ {
+ "git": {
+ "name": ".",
+ "remote": "https://github.com/googleapis/java-bigquerystorage.git",
+ "sha": "6dc9d2b59699816132768c3e8c81b7769b700a8b"
+ }
+ },
+ {
+ "git": {
+ "name": "synthtool",
+ "remote": "rpc://devrel/cloud/libraries/tools/autosynth",
+ "sha": "dd7cd93888cbeb1d4c56a1ca814491c7813160e8"
+ }
+ },
{
"generator": {
"name": "artman",
@@ -12,33 +26,33 @@
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "5006247aa157e59118833658084345ee59af7c09",
- "internalRef": "294383128"
+ "sha": "8a36b928873ff9c05b43859b9d4ea14cd205df57",
+ "internalRef": "294459768"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "5006247aa157e59118833658084345ee59af7c09",
- "internalRef": "294383128"
+ "sha": "8a36b928873ff9c05b43859b9d4ea14cd205df57",
+ "internalRef": "294459768"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "5006247aa157e59118833658084345ee59af7c09",
- "internalRef": "294383128"
+ "sha": "8a36b928873ff9c05b43859b9d4ea14cd205df57",
+ "internalRef": "294459768"
}
},
{
"git": {
"name": "googleapis",
"remote": "https://github.com/googleapis/googleapis.git",
- "sha": "5006247aa157e59118833658084345ee59af7c09",
- "internalRef": "294383128",
- "log": "5006247aa157e59118833658084345ee59af7c09\nFix: Make deprecated fields optional\nFix: Deprecate SetLoggingServiceRequest.zone in line with the comments\nFeature: Add resource name method signatures where appropriate\n\nPiperOrigin-RevId: 294383128\n\neabba40dac05c5cbe0fca3a35761b17e372036c4\nFix: C# and PHP package/namespace capitalization for BigQuery Storage v1.\n\nPiperOrigin-RevId: 294382444\n\nf8d9a858a7a55eba8009a23aa3f5cc5fe5e88dde\nfix: artman configuration file for bigtable-admin\n\nPiperOrigin-RevId: 294322616\n\n0f29555d1cfcf96add5c0b16b089235afbe9b1a9\nAPI definition for (not-yet-launched) GCS gRPC.\n\nPiperOrigin-RevId: 294321472\n\nfcc86bee0e84dc11e9abbff8d7c3529c0626f390\nfix: Bigtable Admin v2\n\nChange LRO metadata from PartialUpdateInstanceMetadata\nto UpdateInstanceMetadata. (Otherwise, it will not build.)\n\nPiperOrigin-RevId: 294264582\n\n6d9361eae2ebb3f42d8c7ce5baf4bab966fee7c0\nrefactor: Add annotations to Bigtable Admin v2.\n\nPiperOrigin-RevId: 294243406\n\nad7616f3fc8e123451c8b3a7987bc91cea9e6913\nFix: Resource type in CreateLogMetricRequest should use logging.googleapis.com.\nFix: ListLogEntries should have a method signature for convenience of calling it.\n\nPiperOrigin-RevId: 294222165\n\n63796fcbb08712676069e20a3e455c9f7aa21026\nFix: Remove extraneous resource definition for cloudkms.googleapis.com/CryptoKey.\n\nPiperOrigin-RevId: 294176658\n\n"
+ "sha": "8a36b928873ff9c05b43859b9d4ea14cd205df57",
+ "internalRef": "294459768",
+ "log": "8a36b928873ff9c05b43859b9d4ea14cd205df57\nFix: Define the \"bigquery.googleapis.com/Table\" resource in the BigQuery Storage API (v1beta2).\n\nPiperOrigin-RevId: 294459768\n\nc7a3caa2c40c49f034a3c11079dd90eb24987047\nFix: Define the \"bigquery.googleapis.com/Table\" resource in the BigQuery Storage API (v1).\n\nPiperOrigin-RevId: 294456889\n\n"
}
},
{