() {
+ public WriteMode findValueByNumber(int number) {
+ return WriteMode.forNumber(number);
+ }
+ };
+
+ public final com.google.protobuf.Descriptors.EnumValueDescriptor getValueDescriptor() {
+ if (this == UNRECOGNIZED) {
+ throw new java.lang.IllegalStateException(
+ "Can't get the descriptor of an unrecognized enum value.");
+ }
+ return getDescriptor().getValues().get(ordinal());
+ }
+
+ public final com.google.protobuf.Descriptors.EnumDescriptor getDescriptorForType() {
+ return getDescriptor();
+ }
+
+ public static final com.google.protobuf.Descriptors.EnumDescriptor getDescriptor() {
+ return com.google.cloud.bigquery.storage.v1.WriteStream.getDescriptor().getEnumTypes().get(1);
+ }
+
+ private static final WriteMode[] VALUES = values();
+
+ public static WriteMode valueOf(com.google.protobuf.Descriptors.EnumValueDescriptor desc) {
+ if (desc.getType() != getDescriptor()) {
+ throw new java.lang.IllegalArgumentException("EnumValueDescriptor is not for this type.");
+ }
+ if (desc.getIndex() == -1) {
+ return UNRECOGNIZED;
+ }
+ return VALUES[desc.getIndex()];
+ }
+
+ private final int value;
+
+ private WriteMode(int value) {
+ this.value = value;
+ }
+
+ // @@protoc_insertion_point(enum_scope:google.cloud.bigquery.storage.v1.WriteStream.WriteMode)
+ }
+
public static final int NAME_FIELD_NUMBER = 1;
private volatile java.lang.Object name_;
/**
@@ -612,6 +757,48 @@ public com.google.cloud.bigquery.storage.v1.TableSchemaOrBuilder getTableSchemaO
return getTableSchema();
}
+ public static final int WRITE_MODE_FIELD_NUMBER = 7;
+ private int writeMode_;
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The enum numeric value on the wire for writeMode.
+ */
+ @java.lang.Override
+ public int getWriteModeValue() {
+ return writeMode_;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The writeMode.
+ */
+ @java.lang.Override
+ public com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode getWriteMode() {
+ @SuppressWarnings("deprecation")
+ com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode result =
+ com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode.valueOf(writeMode_);
+ return result == null
+ ? com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode.UNRECOGNIZED
+ : result;
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
@@ -642,6 +829,11 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (tableSchema_ != null) {
output.writeMessage(5, getTableSchema());
}
+ if (writeMode_
+ != com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode.WRITE_MODE_UNSPECIFIED
+ .getNumber()) {
+ output.writeEnum(7, writeMode_);
+ }
unknownFields.writeTo(output);
}
@@ -667,6 +859,11 @@ public int getSerializedSize() {
if (tableSchema_ != null) {
size += com.google.protobuf.CodedOutputStream.computeMessageSize(5, getTableSchema());
}
+ if (writeMode_
+ != com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode.WRITE_MODE_UNSPECIFIED
+ .getNumber()) {
+ size += com.google.protobuf.CodedOutputStream.computeEnumSize(7, writeMode_);
+ }
size += unknownFields.getSerializedSize();
memoizedSize = size;
return size;
@@ -697,6 +894,7 @@ public boolean equals(final java.lang.Object obj) {
if (hasTableSchema()) {
if (!getTableSchema().equals(other.getTableSchema())) return false;
}
+ if (writeMode_ != other.writeMode_) return false;
if (!unknownFields.equals(other.unknownFields)) return false;
return true;
}
@@ -724,6 +922,8 @@ public int hashCode() {
hash = (37 * hash) + TABLE_SCHEMA_FIELD_NUMBER;
hash = (53 * hash) + getTableSchema().hashCode();
}
+ hash = (37 * hash) + WRITE_MODE_FIELD_NUMBER;
+ hash = (53 * hash) + writeMode_;
hash = (29 * hash) + unknownFields.hashCode();
memoizedHashCode = hash;
return hash;
@@ -891,6 +1091,8 @@ public Builder clear() {
tableSchema_ = null;
tableSchemaBuilder_ = null;
}
+ writeMode_ = 0;
+
return this;
}
@@ -935,6 +1137,7 @@ public com.google.cloud.bigquery.storage.v1.WriteStream buildPartial() {
} else {
result.tableSchema_ = tableSchemaBuilder_.build();
}
+ result.writeMode_ = writeMode_;
onBuilt();
return result;
}
@@ -1001,6 +1204,9 @@ public Builder mergeFrom(com.google.cloud.bigquery.storage.v1.WriteStream other)
if (other.hasTableSchema()) {
mergeTableSchema(other.getTableSchema());
}
+ if (other.writeMode_ != 0) {
+ setWriteModeValue(other.getWriteModeValue());
+ }
this.mergeUnknownFields(other.unknownFields);
onChanged();
return this;
@@ -1913,6 +2119,109 @@ public com.google.cloud.bigquery.storage.v1.TableSchemaOrBuilder getTableSchemaO
return tableSchemaBuilder_;
}
+ private int writeMode_ = 0;
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The enum numeric value on the wire for writeMode.
+ */
+ @java.lang.Override
+ public int getWriteModeValue() {
+ return writeMode_;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @param value The enum numeric value on the wire for writeMode to set.
+ * @return This builder for chaining.
+ */
+ public Builder setWriteModeValue(int value) {
+
+ writeMode_ = value;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The writeMode.
+ */
+ @java.lang.Override
+ public com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode getWriteMode() {
+ @SuppressWarnings("deprecation")
+ com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode result =
+ com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode.valueOf(writeMode_);
+ return result == null
+ ? com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode.UNRECOGNIZED
+ : result;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @param value The writeMode to set.
+ * @return This builder for chaining.
+ */
+ public Builder setWriteMode(com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode value) {
+ if (value == null) {
+ throw new NullPointerException();
+ }
+
+ writeMode_ = value.getNumber();
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearWriteMode() {
+
+ writeMode_ = 0;
+ onChanged();
+ return this;
+ }
+
@java.lang.Override
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
diff --git a/proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/WriteStreamOrBuilder.java b/proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/WriteStreamOrBuilder.java
index c14850b8a1..029de2eff0 100644
--- a/proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/WriteStreamOrBuilder.java
+++ b/proto-google-cloud-bigquerystorage-v1/src/main/java/com/google/cloud/bigquery/storage/v1/WriteStreamOrBuilder.java
@@ -216,4 +216,33 @@ public interface WriteStreamOrBuilder
*
*/
com.google.cloud.bigquery.storage.v1.TableSchemaOrBuilder getTableSchemaOrBuilder();
+
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The enum numeric value on the wire for writeMode.
+ */
+ int getWriteModeValue();
+ /**
+ *
+ *
+ *
+ * Immutable. Mode of the stream.
+ *
+ *
+ *
+ * .google.cloud.bigquery.storage.v1.WriteStream.WriteMode write_mode = 7 [(.google.api.field_behavior) = IMMUTABLE];
+ *
+ *
+ * @return The writeMode.
+ */
+ com.google.cloud.bigquery.storage.v1.WriteStream.WriteMode getWriteMode();
}
diff --git a/proto-google-cloud-bigquerystorage-v1/src/main/proto/google/cloud/bigquery/storage/v1/stream.proto b/proto-google-cloud-bigquerystorage-v1/src/main/proto/google/cloud/bigquery/storage/v1/stream.proto
index dc62e8c00c..0b0bc1ad05 100644
--- a/proto-google-cloud-bigquerystorage-v1/src/main/proto/google/cloud/bigquery/storage/v1/stream.proto
+++ b/proto-google-cloud-bigquerystorage-v1/src/main/proto/google/cloud/bigquery/storage/v1/stream.proto
@@ -171,6 +171,16 @@ message WriteStream {
BUFFERED = 3;
}
+ // Mode enum of the stream.
+ enum WriteMode {
+ // Unknown type.
+ WRITE_MODE_UNSPECIFIED = 0;
+
+ // Insert new records into the table.
+ // It is the default value if customers do not specify it.
+ INSERT = 1;
+ }
+
// Output only. Name of the stream, in the form
// `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
@@ -193,4 +203,7 @@ message WriteStream {
// compatible with this schema to send in initial `AppendRowsRequest`.
// The table schema could go out of date during the life time of the stream.
TableSchema table_schema = 5 [(google.api.field_behavior) = OUTPUT_ONLY];
+
+ // Immutable. Mode of the stream.
+ WriteMode write_mode = 7 [(google.api.field_behavior) = IMMUTABLE];
}