diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSourceConfig.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSourceConfig.java
index c3a42f63e924..bc5d433af9ea 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSourceConfig.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSourceConfig.java
@@ -184,6 +184,26 @@ public int getMaxConcurrentCdcTasks() {
return maxConcurrentCdcTasks_;
}
+ public static final int MAX_CONCURRENT_BACKFILL_TASKS_FIELD_NUMBER = 4;
+ private int maxConcurrentBackfillTasks_ = 0;
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ @java.lang.Override
+ public int getMaxConcurrentBackfillTasks() {
+ return maxConcurrentBackfillTasks_;
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
@@ -207,6 +227,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (maxConcurrentCdcTasks_ != 0) {
output.writeInt32(3, maxConcurrentCdcTasks_);
}
+ if (maxConcurrentBackfillTasks_ != 0) {
+ output.writeInt32(4, maxConcurrentBackfillTasks_);
+ }
getUnknownFields().writeTo(output);
}
@@ -225,6 +248,10 @@ public int getSerializedSize() {
if (maxConcurrentCdcTasks_ != 0) {
size += com.google.protobuf.CodedOutputStream.computeInt32Size(3, maxConcurrentCdcTasks_);
}
+ if (maxConcurrentBackfillTasks_ != 0) {
+ size +=
+ com.google.protobuf.CodedOutputStream.computeInt32Size(4, maxConcurrentBackfillTasks_);
+ }
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
@@ -250,6 +277,7 @@ public boolean equals(final java.lang.Object obj) {
if (!getExcludeObjects().equals(other.getExcludeObjects())) return false;
}
if (getMaxConcurrentCdcTasks() != other.getMaxConcurrentCdcTasks()) return false;
+ if (getMaxConcurrentBackfillTasks() != other.getMaxConcurrentBackfillTasks()) return false;
if (!getUnknownFields().equals(other.getUnknownFields())) return false;
return true;
}
@@ -271,6 +299,8 @@ public int hashCode() {
}
hash = (37 * hash) + MAX_CONCURRENT_CDC_TASKS_FIELD_NUMBER;
hash = (53 * hash) + getMaxConcurrentCdcTasks();
+ hash = (37 * hash) + MAX_CONCURRENT_BACKFILL_TASKS_FIELD_NUMBER;
+ hash = (53 * hash) + getMaxConcurrentBackfillTasks();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
@@ -421,6 +451,7 @@ public Builder clear() {
excludeObjectsBuilder_ = null;
}
maxConcurrentCdcTasks_ = 0;
+ maxConcurrentBackfillTasks_ = 0;
return this;
}
@@ -468,6 +499,9 @@ private void buildPartial0(com.google.cloud.datastream.v1.MysqlSourceConfig resu
if (((from_bitField0_ & 0x00000004) != 0)) {
result.maxConcurrentCdcTasks_ = maxConcurrentCdcTasks_;
}
+ if (((from_bitField0_ & 0x00000008) != 0)) {
+ result.maxConcurrentBackfillTasks_ = maxConcurrentBackfillTasks_;
+ }
}
@java.lang.Override
@@ -525,6 +559,9 @@ public Builder mergeFrom(com.google.cloud.datastream.v1.MysqlSourceConfig other)
if (other.getMaxConcurrentCdcTasks() != 0) {
setMaxConcurrentCdcTasks(other.getMaxConcurrentCdcTasks());
}
+ if (other.getMaxConcurrentBackfillTasks() != 0) {
+ setMaxConcurrentBackfillTasks(other.getMaxConcurrentBackfillTasks());
+ }
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
@@ -569,6 +606,12 @@ public Builder mergeFrom(
bitField0_ |= 0x00000004;
break;
} // case 24
+ case 32:
+ {
+ maxConcurrentBackfillTasks_ = input.readInt32();
+ bitField0_ |= 0x00000008;
+ break;
+ } // case 32
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -1012,6 +1055,65 @@ public Builder clearMaxConcurrentCdcTasks() {
return this;
}
+ private int maxConcurrentBackfillTasks_;
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ @java.lang.Override
+ public int getMaxConcurrentBackfillTasks() {
+ return maxConcurrentBackfillTasks_;
+ }
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @param value The maxConcurrentBackfillTasks to set.
+ * @return This builder for chaining.
+ */
+ public Builder setMaxConcurrentBackfillTasks(int value) {
+
+ maxConcurrentBackfillTasks_ = value;
+ bitField0_ |= 0x00000008;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearMaxConcurrentBackfillTasks() {
+ bitField0_ = (bitField0_ & ~0x00000008);
+ maxConcurrentBackfillTasks_ = 0;
+ onChanged();
+ return this;
+ }
+
@java.lang.Override
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSourceConfigOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSourceConfigOrBuilder.java
index a547dbbf4e9c..9f5406854cd5 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSourceConfigOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSourceConfigOrBuilder.java
@@ -106,4 +106,19 @@ public interface MysqlSourceConfigOrBuilder
* @return The maxConcurrentCdcTasks.
*/
int getMaxConcurrentCdcTasks();
+
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ int getMaxConcurrentBackfillTasks();
}
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSslConfig.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSslConfig.java
index 3c5b0cb2c9d7..b7ca66a6f088 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSslConfig.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSslConfig.java
@@ -223,8 +223,8 @@ public boolean getClientCertificateSet() {
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
@@ -247,8 +247,8 @@ public java.lang.String getCaCertificate() {
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
@@ -1084,8 +1084,8 @@ public Builder clearClientCertificateSet() {
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
@@ -1107,8 +1107,8 @@ public java.lang.String getCaCertificate() {
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
@@ -1130,8 +1130,8 @@ public com.google.protobuf.ByteString getCaCertificateBytes() {
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
@@ -1152,8 +1152,8 @@ public Builder setCaCertificate(java.lang.String value) {
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
@@ -1170,8 +1170,8 @@ public Builder clearCaCertificate() {
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSslConfigOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSslConfigOrBuilder.java
index 19562b09cb5f..07af8fd62db3 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSslConfigOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/MysqlSslConfigOrBuilder.java
@@ -111,8 +111,8 @@ public interface MysqlSslConfigOrBuilder
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
@@ -124,8 +124,8 @@ public interface MysqlSslConfigOrBuilder
*
*
*
- * Input only. PEM-encoded certificate of the CA that signed the source database
- * server's certificate.
+ * Input only. PEM-encoded certificate of the CA that signed the source
+ * database server's certificate.
*
*
* string ca_certificate = 5 [(.google.api.field_behavior) = INPUT_ONLY];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OperationMetadata.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OperationMetadata.java
index b27109694984..995f8801b199 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OperationMetadata.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OperationMetadata.java
@@ -329,8 +329,9 @@ public com.google.protobuf.ByteString getStatusMessageBytes() {
*
* Output only. Identifies whether the user has requested cancellation
* of the operation. Operations that have successfully been cancelled
- * have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
- * corresponding to `Code.CANCELLED`.
+ * have [Operation.error][] value with a
+ * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`.
*
*
* bool requested_cancellation = 6 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -1694,8 +1695,9 @@ public Builder setStatusMessageBytes(com.google.protobuf.ByteString value) {
*
* Output only. Identifies whether the user has requested cancellation
* of the operation. Operations that have successfully been cancelled
- * have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
- * corresponding to `Code.CANCELLED`.
+ * have [Operation.error][] value with a
+ * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`.
*
*
* bool requested_cancellation = 6 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -1712,8 +1714,9 @@ public boolean getRequestedCancellation() {
*
* Output only. Identifies whether the user has requested cancellation
* of the operation. Operations that have successfully been cancelled
- * have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
- * corresponding to `Code.CANCELLED`.
+ * have [Operation.error][] value with a
+ * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`.
*
*
* bool requested_cancellation = 6 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -1734,8 +1737,9 @@ public Builder setRequestedCancellation(boolean value) {
*
* Output only. Identifies whether the user has requested cancellation
* of the operation. Operations that have successfully been cancelled
- * have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
- * corresponding to `Code.CANCELLED`.
+ * have [Operation.error][] value with a
+ * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`.
*
*
* bool requested_cancellation = 6 [(.google.api.field_behavior) = OUTPUT_ONLY];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OperationMetadataOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OperationMetadataOrBuilder.java
index fd0a674fad61..1590aa252da8 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OperationMetadataOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OperationMetadataOrBuilder.java
@@ -180,8 +180,9 @@ public interface OperationMetadataOrBuilder
*
* Output only. Identifies whether the user has requested cancellation
* of the operation. Operations that have successfully been cancelled
- * have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
- * corresponding to `Code.CANCELLED`.
+ * have [Operation.error][] value with a
+ * [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ * `Code.CANCELLED`.
*
*
* bool requested_cancellation = 6 [(.google.api.field_behavior) = OUTPUT_ONLY];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OracleSourceConfig.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OracleSourceConfig.java
index d057a866c1ce..c754794d7d5d 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OracleSourceConfig.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OracleSourceConfig.java
@@ -1095,8 +1095,8 @@ public com.google.cloud.datastream.v1.OracleRdbmsOrBuilder getExcludeObjectsOrBu
*
*
*
- * Maximum number of concurrent CDC tasks. The number should be non negative.
- * If not set (or set to 0), the system's default value will be used.
+ * Maximum number of concurrent CDC tasks. The number should be non-negative.
+ * If not set (or set to 0), the system's default value is used.
*
*
* int32 max_concurrent_cdc_tasks = 3;
@@ -1108,6 +1108,25 @@ public int getMaxConcurrentCdcTasks() {
return maxConcurrentCdcTasks_;
}
+ public static final int MAX_CONCURRENT_BACKFILL_TASKS_FIELD_NUMBER = 4;
+ private int maxConcurrentBackfillTasks_ = 0;
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be
+ * non-negative. If not set (or set to 0), the system's default value is used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ @java.lang.Override
+ public int getMaxConcurrentBackfillTasks() {
+ return maxConcurrentBackfillTasks_;
+ }
+
public static final int DROP_LARGE_OBJECTS_FIELD_NUMBER = 100;
/**
*
@@ -1170,7 +1189,7 @@ public com.google.cloud.datastream.v1.OracleSourceConfig.DropLargeObjects getDro
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -1187,7 +1206,7 @@ public boolean hasStreamLargeObjects() {
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -1210,7 +1229,7 @@ public boolean hasStreamLargeObjects() {
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -1251,6 +1270,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (maxConcurrentCdcTasks_ != 0) {
output.writeInt32(3, maxConcurrentCdcTasks_);
}
+ if (maxConcurrentBackfillTasks_ != 0) {
+ output.writeInt32(4, maxConcurrentBackfillTasks_);
+ }
if (largeObjectsHandlingCase_ == 100) {
output.writeMessage(
100,
@@ -1281,6 +1303,10 @@ public int getSerializedSize() {
if (maxConcurrentCdcTasks_ != 0) {
size += com.google.protobuf.CodedOutputStream.computeInt32Size(3, maxConcurrentCdcTasks_);
}
+ if (maxConcurrentBackfillTasks_ != 0) {
+ size +=
+ com.google.protobuf.CodedOutputStream.computeInt32Size(4, maxConcurrentBackfillTasks_);
+ }
if (largeObjectsHandlingCase_ == 100) {
size +=
com.google.protobuf.CodedOutputStream.computeMessageSize(
@@ -1320,6 +1346,7 @@ public boolean equals(final java.lang.Object obj) {
if (!getExcludeObjects().equals(other.getExcludeObjects())) return false;
}
if (getMaxConcurrentCdcTasks() != other.getMaxConcurrentCdcTasks()) return false;
+ if (getMaxConcurrentBackfillTasks() != other.getMaxConcurrentBackfillTasks()) return false;
if (!getLargeObjectsHandlingCase().equals(other.getLargeObjectsHandlingCase())) return false;
switch (largeObjectsHandlingCase_) {
case 100:
@@ -1352,6 +1379,8 @@ public int hashCode() {
}
hash = (37 * hash) + MAX_CONCURRENT_CDC_TASKS_FIELD_NUMBER;
hash = (53 * hash) + getMaxConcurrentCdcTasks();
+ hash = (37 * hash) + MAX_CONCURRENT_BACKFILL_TASKS_FIELD_NUMBER;
+ hash = (53 * hash) + getMaxConcurrentBackfillTasks();
switch (largeObjectsHandlingCase_) {
case 100:
hash = (37 * hash) + DROP_LARGE_OBJECTS_FIELD_NUMBER;
@@ -1514,6 +1543,7 @@ public Builder clear() {
excludeObjectsBuilder_ = null;
}
maxConcurrentCdcTasks_ = 0;
+ maxConcurrentBackfillTasks_ = 0;
if (dropLargeObjectsBuilder_ != null) {
dropLargeObjectsBuilder_.clear();
}
@@ -1570,6 +1600,9 @@ private void buildPartial0(com.google.cloud.datastream.v1.OracleSourceConfig res
if (((from_bitField0_ & 0x00000004) != 0)) {
result.maxConcurrentCdcTasks_ = maxConcurrentCdcTasks_;
}
+ if (((from_bitField0_ & 0x00000008) != 0)) {
+ result.maxConcurrentBackfillTasks_ = maxConcurrentBackfillTasks_;
+ }
}
private void buildPartialOneofs(com.google.cloud.datastream.v1.OracleSourceConfig result) {
@@ -1638,6 +1671,9 @@ public Builder mergeFrom(com.google.cloud.datastream.v1.OracleSourceConfig other
if (other.getMaxConcurrentCdcTasks() != 0) {
setMaxConcurrentCdcTasks(other.getMaxConcurrentCdcTasks());
}
+ if (other.getMaxConcurrentBackfillTasks() != 0) {
+ setMaxConcurrentBackfillTasks(other.getMaxConcurrentBackfillTasks());
+ }
switch (other.getLargeObjectsHandlingCase()) {
case DROP_LARGE_OBJECTS:
{
@@ -1698,6 +1734,12 @@ public Builder mergeFrom(
bitField0_ |= 0x00000004;
break;
} // case 24
+ case 32:
+ {
+ maxConcurrentBackfillTasks_ = input.readInt32();
+ bitField0_ |= 0x00000008;
+ break;
+ } // case 32
case 802:
{
input.readMessage(
@@ -2118,8 +2160,8 @@ public com.google.cloud.datastream.v1.OracleRdbmsOrBuilder getExcludeObjectsOrBu
*
*
*
- * Maximum number of concurrent CDC tasks. The number should be non negative.
- * If not set (or set to 0), the system's default value will be used.
+ * Maximum number of concurrent CDC tasks. The number should be non-negative.
+ * If not set (or set to 0), the system's default value is used.
*
*
* int32 max_concurrent_cdc_tasks = 3;
@@ -2134,8 +2176,8 @@ public int getMaxConcurrentCdcTasks() {
*
*
*
- * Maximum number of concurrent CDC tasks. The number should be non negative.
- * If not set (or set to 0), the system's default value will be used.
+ * Maximum number of concurrent CDC tasks. The number should be non-negative.
+ * If not set (or set to 0), the system's default value is used.
*
*
* int32 max_concurrent_cdc_tasks = 3;
@@ -2154,8 +2196,8 @@ public Builder setMaxConcurrentCdcTasks(int value) {
*
*
*
- * Maximum number of concurrent CDC tasks. The number should be non negative.
- * If not set (or set to 0), the system's default value will be used.
+ * Maximum number of concurrent CDC tasks. The number should be non-negative.
+ * If not set (or set to 0), the system's default value is used.
*
*
* int32 max_concurrent_cdc_tasks = 3;
@@ -2169,6 +2211,62 @@ public Builder clearMaxConcurrentCdcTasks() {
return this;
}
+ private int maxConcurrentBackfillTasks_;
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be
+ * non-negative. If not set (or set to 0), the system's default value is used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ @java.lang.Override
+ public int getMaxConcurrentBackfillTasks() {
+ return maxConcurrentBackfillTasks_;
+ }
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be
+ * non-negative. If not set (or set to 0), the system's default value is used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @param value The maxConcurrentBackfillTasks to set.
+ * @return This builder for chaining.
+ */
+ public Builder setMaxConcurrentBackfillTasks(int value) {
+
+ maxConcurrentBackfillTasks_ = value;
+ bitField0_ |= 0x00000008;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be
+ * non-negative. If not set (or set to 0), the system's default value is used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearMaxConcurrentBackfillTasks() {
+ bitField0_ = (bitField0_ & ~0x00000008);
+ maxConcurrentBackfillTasks_ = 0;
+ onChanged();
+ return this;
+ }
+
private com.google.protobuf.SingleFieldBuilderV3<
com.google.cloud.datastream.v1.OracleSourceConfig.DropLargeObjects,
com.google.cloud.datastream.v1.OracleSourceConfig.DropLargeObjects.Builder,
@@ -2422,7 +2520,7 @@ public Builder clearDropLargeObjects() {
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -2439,7 +2537,7 @@ public boolean hasStreamLargeObjects() {
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -2470,7 +2568,7 @@ public boolean hasStreamLargeObjects() {
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -2495,7 +2593,7 @@ public Builder setStreamLargeObjects(
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -2518,7 +2616,7 @@ public Builder setStreamLargeObjects(
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -2556,7 +2654,7 @@ public Builder mergeStreamLargeObjects(
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -2583,7 +2681,7 @@ public Builder clearStreamLargeObjects() {
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -2598,7 +2696,7 @@ public Builder clearStreamLargeObjects() {
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -2623,7 +2721,7 @@ public Builder clearStreamLargeObjects() {
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OracleSourceConfigOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OracleSourceConfigOrBuilder.java
index f21df17f7bcd..d69281c22a50 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OracleSourceConfigOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/OracleSourceConfigOrBuilder.java
@@ -97,8 +97,8 @@ public interface OracleSourceConfigOrBuilder
*
*
*
- * Maximum number of concurrent CDC tasks. The number should be non negative.
- * If not set (or set to 0), the system's default value will be used.
+ * Maximum number of concurrent CDC tasks. The number should be non-negative.
+ * If not set (or set to 0), the system's default value is used.
*
*
* int32 max_concurrent_cdc_tasks = 3;
@@ -107,6 +107,20 @@ public interface OracleSourceConfigOrBuilder
*/
int getMaxConcurrentCdcTasks();
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be
+ * non-negative. If not set (or set to 0), the system's default value is used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 4;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ int getMaxConcurrentBackfillTasks();
+
/**
*
*
@@ -150,7 +164,7 @@ public interface OracleSourceConfigOrBuilder
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -164,7 +178,7 @@ public interface OracleSourceConfigOrBuilder
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
@@ -178,7 +192,7 @@ public interface OracleSourceConfigOrBuilder
*
*
*
- * Stream large object values.
+ * Stream large object values. NOTE: This feature is currently experimental.
*
*
*
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PostgresqlSourceConfig.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PostgresqlSourceConfig.java
index d9d42f296b0b..bbf4f5218472 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PostgresqlSourceConfig.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PostgresqlSourceConfig.java
@@ -176,11 +176,13 @@ public com.google.cloud.datastream.v1.PostgresqlRdbmsOrBuilder getExcludeObjects
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @return The replicationSlot.
*/
@@ -200,11 +202,13 @@ public java.lang.String getReplicationSlot() {
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @return The bytes for replicationSlot.
*/
@@ -229,8 +233,8 @@ public com.google.protobuf.ByteString getReplicationSlotBytes() {
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -253,8 +257,8 @@ public java.lang.String getPublication() {
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -274,6 +278,26 @@ public com.google.protobuf.ByteString getPublicationBytes() {
}
}
+ public static final int MAX_CONCURRENT_BACKFILL_TASKS_FIELD_NUMBER = 5;
+ private int maxConcurrentBackfillTasks_ = 0;
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 5;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ @java.lang.Override
+ public int getMaxConcurrentBackfillTasks() {
+ return maxConcurrentBackfillTasks_;
+ }
+
private byte memoizedIsInitialized = -1;
@java.lang.Override
@@ -300,6 +324,9 @@ public void writeTo(com.google.protobuf.CodedOutputStream output) throws java.io
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(publication_)) {
com.google.protobuf.GeneratedMessageV3.writeString(output, 4, publication_);
}
+ if (maxConcurrentBackfillTasks_ != 0) {
+ output.writeInt32(5, maxConcurrentBackfillTasks_);
+ }
getUnknownFields().writeTo(output);
}
@@ -321,6 +348,10 @@ public int getSerializedSize() {
if (!com.google.protobuf.GeneratedMessageV3.isStringEmpty(publication_)) {
size += com.google.protobuf.GeneratedMessageV3.computeStringSize(4, publication_);
}
+ if (maxConcurrentBackfillTasks_ != 0) {
+ size +=
+ com.google.protobuf.CodedOutputStream.computeInt32Size(5, maxConcurrentBackfillTasks_);
+ }
size += getUnknownFields().getSerializedSize();
memoizedSize = size;
return size;
@@ -347,6 +378,7 @@ public boolean equals(final java.lang.Object obj) {
}
if (!getReplicationSlot().equals(other.getReplicationSlot())) return false;
if (!getPublication().equals(other.getPublication())) return false;
+ if (getMaxConcurrentBackfillTasks() != other.getMaxConcurrentBackfillTasks()) return false;
if (!getUnknownFields().equals(other.getUnknownFields())) return false;
return true;
}
@@ -370,6 +402,8 @@ public int hashCode() {
hash = (53 * hash) + getReplicationSlot().hashCode();
hash = (37 * hash) + PUBLICATION_FIELD_NUMBER;
hash = (53 * hash) + getPublication().hashCode();
+ hash = (37 * hash) + MAX_CONCURRENT_BACKFILL_TASKS_FIELD_NUMBER;
+ hash = (53 * hash) + getMaxConcurrentBackfillTasks();
hash = (29 * hash) + getUnknownFields().hashCode();
memoizedHashCode = hash;
return hash;
@@ -522,6 +556,7 @@ public Builder clear() {
}
replicationSlot_ = "";
publication_ = "";
+ maxConcurrentBackfillTasks_ = 0;
return this;
}
@@ -572,6 +607,9 @@ private void buildPartial0(com.google.cloud.datastream.v1.PostgresqlSourceConfig
if (((from_bitField0_ & 0x00000008) != 0)) {
result.publication_ = publication_;
}
+ if (((from_bitField0_ & 0x00000010) != 0)) {
+ result.maxConcurrentBackfillTasks_ = maxConcurrentBackfillTasks_;
+ }
}
@java.lang.Override
@@ -636,6 +674,9 @@ public Builder mergeFrom(com.google.cloud.datastream.v1.PostgresqlSourceConfig o
bitField0_ |= 0x00000008;
onChanged();
}
+ if (other.getMaxConcurrentBackfillTasks() != 0) {
+ setMaxConcurrentBackfillTasks(other.getMaxConcurrentBackfillTasks());
+ }
this.mergeUnknownFields(other.getUnknownFields());
onChanged();
return this;
@@ -686,6 +727,12 @@ public Builder mergeFrom(
bitField0_ |= 0x00000008;
break;
} // case 34
+ case 40:
+ {
+ maxConcurrentBackfillTasks_ = input.readInt32();
+ bitField0_ |= 0x00000010;
+ break;
+ } // case 40
default:
{
if (!super.parseUnknownField(input, extensionRegistry, tag)) {
@@ -1080,11 +1127,13 @@ public com.google.cloud.datastream.v1.PostgresqlRdbmsOrBuilder getExcludeObjects
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @return The replicationSlot.
*/
@@ -1103,11 +1152,13 @@ public java.lang.String getReplicationSlot() {
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @return The bytes for replicationSlot.
*/
@@ -1126,11 +1177,13 @@ public com.google.protobuf.ByteString getReplicationSlotBytes() {
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @param value The replicationSlot to set.
* @return This builder for chaining.
@@ -1148,11 +1201,13 @@ public Builder setReplicationSlot(java.lang.String value) {
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @return This builder for chaining.
*/
@@ -1166,11 +1221,13 @@ public Builder clearReplicationSlot() {
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @param value The bytes for replicationSlot to set.
* @return This builder for chaining.
@@ -1191,8 +1248,8 @@ public Builder setReplicationSlotBytes(com.google.protobuf.ByteString value) {
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -1214,8 +1271,8 @@ public java.lang.String getPublication() {
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -1237,8 +1294,8 @@ public com.google.protobuf.ByteString getPublicationBytes() {
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -1259,8 +1316,8 @@ public Builder setPublication(java.lang.String value) {
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -1277,8 +1334,8 @@ public Builder clearPublication() {
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -1297,6 +1354,65 @@ public Builder setPublicationBytes(com.google.protobuf.ByteString value) {
return this;
}
+ private int maxConcurrentBackfillTasks_;
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 5;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ @java.lang.Override
+ public int getMaxConcurrentBackfillTasks() {
+ return maxConcurrentBackfillTasks_;
+ }
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 5;
+ *
+ * @param value The maxConcurrentBackfillTasks to set.
+ * @return This builder for chaining.
+ */
+ public Builder setMaxConcurrentBackfillTasks(int value) {
+
+ maxConcurrentBackfillTasks_ = value;
+ bitField0_ |= 0x00000010;
+ onChanged();
+ return this;
+ }
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 5;
+ *
+ * @return This builder for chaining.
+ */
+ public Builder clearMaxConcurrentBackfillTasks() {
+ bitField0_ = (bitField0_ & ~0x00000010);
+ maxConcurrentBackfillTasks_ = 0;
+ onChanged();
+ return this;
+ }
+
@java.lang.Override
public final Builder setUnknownFields(final com.google.protobuf.UnknownFieldSet unknownFields) {
return super.setUnknownFields(unknownFields);
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PostgresqlSourceConfigOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PostgresqlSourceConfigOrBuilder.java
index 392de3dc37b2..ccbfe53d519a 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PostgresqlSourceConfigOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PostgresqlSourceConfigOrBuilder.java
@@ -97,11 +97,13 @@ public interface PostgresqlSourceConfigOrBuilder
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @return The replicationSlot.
*/
@@ -110,11 +112,13 @@ public interface PostgresqlSourceConfigOrBuilder
*
*
*
- * Required. The name of the logical replication slot that's configured with the
- * pgoutput plugin.
+ * Required. Immutable. The name of the logical replication slot that's
+ * configured with the pgoutput plugin.
*
*
- * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED];
+ *
+ * string replication_slot = 3 [(.google.api.field_behavior) = REQUIRED, (.google.api.field_behavior) = IMMUTABLE];
+ *
*
* @return The bytes for replicationSlot.
*/
@@ -124,8 +128,8 @@ public interface PostgresqlSourceConfigOrBuilder
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -137,8 +141,8 @@ public interface PostgresqlSourceConfigOrBuilder
*
*
*
- * Required. The name of the publication that includes the set of all tables that are
- * defined in the stream's include_objects.
+ * Required. The name of the publication that includes the set of all tables
+ * that are defined in the stream's include_objects.
*
*
* string publication = 4 [(.google.api.field_behavior) = REQUIRED];
@@ -146,4 +150,19 @@ public interface PostgresqlSourceConfigOrBuilder
* @return The bytes for publication.
*/
com.google.protobuf.ByteString getPublicationBytes();
+
+ /**
+ *
+ *
+ *
+ * Maximum number of concurrent backfill tasks. The number should be non
+ * negative. If not set (or set to 0), the system's default value will be
+ * used.
+ *
+ *
+ * int32 max_concurrent_backfill_tasks = 5;
+ *
+ * @return The maxConcurrentBackfillTasks.
+ */
+ int getMaxConcurrentBackfillTasks();
}
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PrivateConnection.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PrivateConnection.java
index 064647101b3e..48e68c9bf256 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PrivateConnection.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PrivateConnection.java
@@ -653,7 +653,8 @@ public com.google.cloud.datastream.v1.PrivateConnection.State getState() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
* .google.cloud.datastream.v1.Error error = 7 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -669,7 +670,8 @@ public boolean hasError() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
* .google.cloud.datastream.v1.Error error = 7 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -685,7 +687,8 @@ public com.google.cloud.datastream.v1.Error getError() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
* .google.cloud.datastream.v1.Error error = 7 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -2208,7 +2211,8 @@ public Builder clearState() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
@@ -2224,7 +2228,8 @@ public boolean hasError() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
@@ -2244,7 +2249,8 @@ public com.google.cloud.datastream.v1.Error getError() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
@@ -2268,7 +2274,8 @@ public Builder setError(com.google.cloud.datastream.v1.Error value) {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
@@ -2289,7 +2296,8 @@ public Builder setError(com.google.cloud.datastream.v1.Error.Builder builderForV
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
@@ -2316,7 +2324,8 @@ public Builder mergeError(com.google.cloud.datastream.v1.Error value) {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
@@ -2337,7 +2346,8 @@ public Builder clearError() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
@@ -2353,7 +2363,8 @@ public com.google.cloud.datastream.v1.Error.Builder getErrorBuilder() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
@@ -2371,7 +2382,8 @@ public com.google.cloud.datastream.v1.ErrorOrBuilder getErrorOrBuilder() {
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
*
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PrivateConnectionOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PrivateConnectionOrBuilder.java
index 224e89bfe1af..fcb83752892b 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PrivateConnectionOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/PrivateConnectionOrBuilder.java
@@ -240,7 +240,8 @@ java.lang.String getLabelsOrDefault(
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
* .google.cloud.datastream.v1.Error error = 7 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -253,7 +254,8 @@ java.lang.String getLabelsOrDefault(
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
* .google.cloud.datastream.v1.Error error = 7 [(.google.api.field_behavior) = OUTPUT_ONLY];
@@ -266,7 +268,8 @@ java.lang.String getLabelsOrDefault(
*
*
*
- * Output only. In case of error, the details of the error in a user-friendly format.
+ * Output only. In case of error, the details of the error in a user-friendly
+ * format.
*
*
* .google.cloud.datastream.v1.Error error = 7 [(.google.api.field_behavior) = OUTPUT_ONLY];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StartBackfillJobRequest.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StartBackfillJobRequest.java
index 7b48d2e913d8..5a2e99856901 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StartBackfillJobRequest.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StartBackfillJobRequest.java
@@ -75,7 +75,8 @@ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
@@ -100,7 +101,8 @@ public java.lang.String getObject() {
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
@@ -470,7 +472,8 @@ public Builder mergeFrom(
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
@@ -494,7 +497,8 @@ public java.lang.String getObject() {
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
@@ -518,7 +522,8 @@ public com.google.protobuf.ByteString getObjectBytes() {
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
@@ -541,7 +546,8 @@ public Builder setObject(java.lang.String value) {
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
@@ -560,7 +566,8 @@ public Builder clearObject() {
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StartBackfillJobRequestOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StartBackfillJobRequestOrBuilder.java
index b4adbe22e5f7..9f94c7fac8db 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StartBackfillJobRequestOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StartBackfillJobRequestOrBuilder.java
@@ -27,7 +27,8 @@ public interface StartBackfillJobRequestOrBuilder
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
@@ -41,7 +42,8 @@ public interface StartBackfillJobRequestOrBuilder
*
*
*
- * Required. The name of the stream object resource to start a backfill job for.
+ * Required. The name of the stream object resource to start a backfill job
+ * for.
*
*
*
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StaticServiceIpConnectivity.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StaticServiceIpConnectivity.java
index 9965364195a2..6adb975dbcdf 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StaticServiceIpConnectivity.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StaticServiceIpConnectivity.java
@@ -22,7 +22,9 @@
*
*
*
- * Static IP address connectivity.
+ * Static IP address connectivity. Used when the source database is configured
+ * to allow incoming connections from the Datastream public IP addresses
+ * for the region specified in the connection profile.
*
*
* Protobuf type {@code google.cloud.datastream.v1.StaticServiceIpConnectivity}
@@ -220,7 +222,9 @@ protected Builder newBuilderForType(com.google.protobuf.GeneratedMessageV3.Build
*
*
*
- * Static IP address connectivity.
+ * Static IP address connectivity. Used when the source database is configured
+ * to allow incoming connections from the Datastream public IP addresses
+ * for the region specified in the connection profile.
*
*
* Protobuf type {@code google.cloud.datastream.v1.StaticServiceIpConnectivity}
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StopBackfillJobRequest.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StopBackfillJobRequest.java
index 9524cb513ade..436d785c1c42 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StopBackfillJobRequest.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StopBackfillJobRequest.java
@@ -76,7 +76,8 @@ public static final com.google.protobuf.Descriptors.Descriptor getDescriptor() {
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
@@ -101,7 +102,8 @@ public java.lang.String getObject() {
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
@@ -472,7 +474,8 @@ public Builder mergeFrom(
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
@@ -496,7 +499,8 @@ public java.lang.String getObject() {
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
@@ -520,7 +524,8 @@ public com.google.protobuf.ByteString getObjectBytes() {
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
@@ -543,7 +548,8 @@ public Builder setObject(java.lang.String value) {
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
@@ -562,7 +568,8 @@ public Builder clearObject() {
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StopBackfillJobRequestOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StopBackfillJobRequestOrBuilder.java
index 2852177482fd..97dac58975d9 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StopBackfillJobRequestOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/StopBackfillJobRequestOrBuilder.java
@@ -27,7 +27,8 @@ public interface StopBackfillJobRequestOrBuilder
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
@@ -41,7 +42,8 @@ public interface StopBackfillJobRequestOrBuilder
*
*
*
- * Required. The name of the stream object resource to stop the backfill job for.
+ * Required. The name of the stream object resource to stop the backfill job
+ * for.
*
*
*
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateConnectionProfileRequest.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateConnectionProfileRequest.java
index 4e41b902cf07..137a6b94669d 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateConnectionProfileRequest.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateConnectionProfileRequest.java
@@ -262,8 +262,8 @@ public com.google.protobuf.ByteString getRequestIdBytes() {
*
*
*
- * Optional. Only validate the connection profile, but don't update any resources.
- * The default is false.
+ * Optional. Only validate the connection profile, but don't update any
+ * resources. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
@@ -1342,8 +1342,8 @@ public Builder setRequestIdBytes(com.google.protobuf.ByteString value) {
*
*
*
- * Optional. Only validate the connection profile, but don't update any resources.
- * The default is false.
+ * Optional. Only validate the connection profile, but don't update any
+ * resources. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
@@ -1358,8 +1358,8 @@ public boolean getValidateOnly() {
*
*
*
- * Optional. Only validate the connection profile, but don't update any resources.
- * The default is false.
+ * Optional. Only validate the connection profile, but don't update any
+ * resources. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
@@ -1378,8 +1378,8 @@ public Builder setValidateOnly(boolean value) {
*
*
*
- * Optional. Only validate the connection profile, but don't update any resources.
- * The default is false.
+ * Optional. Only validate the connection profile, but don't update any
+ * resources. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateConnectionProfileRequestOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateConnectionProfileRequestOrBuilder.java
index cdd173161b0a..ce0220ab04d2 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateConnectionProfileRequestOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateConnectionProfileRequestOrBuilder.java
@@ -163,8 +163,8 @@ public interface UpdateConnectionProfileRequestOrBuilder
*
*
*
- * Optional. Only validate the connection profile, but don't update any resources.
- * The default is false.
+ * Optional. Only validate the connection profile, but don't update any
+ * resources. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateStreamRequest.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateStreamRequest.java
index 77cc04865c28..397bc203fcd7 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateStreamRequest.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateStreamRequest.java
@@ -254,8 +254,8 @@ public com.google.protobuf.ByteString getRequestIdBytes() {
*
*
*
- * Optional. Only validate the stream with the changes, without actually updating it.
- * The default is false.
+ * Optional. Only validate the stream with the changes, without actually
+ * updating it. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
@@ -1323,8 +1323,8 @@ public Builder setRequestIdBytes(com.google.protobuf.ByteString value) {
*
*
*
- * Optional. Only validate the stream with the changes, without actually updating it.
- * The default is false.
+ * Optional. Only validate the stream with the changes, without actually
+ * updating it. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
@@ -1339,8 +1339,8 @@ public boolean getValidateOnly() {
*
*
*
- * Optional. Only validate the stream with the changes, without actually updating it.
- * The default is false.
+ * Optional. Only validate the stream with the changes, without actually
+ * updating it. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
@@ -1359,8 +1359,8 @@ public Builder setValidateOnly(boolean value) {
*
*
*
- * Optional. Only validate the stream with the changes, without actually updating it.
- * The default is false.
+ * Optional. Only validate the stream with the changes, without actually
+ * updating it. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateStreamRequestOrBuilder.java b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateStreamRequestOrBuilder.java
index 3daa8f061aa1..ffe1453e4023 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateStreamRequestOrBuilder.java
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/java/com/google/cloud/datastream/v1/UpdateStreamRequestOrBuilder.java
@@ -160,8 +160,8 @@ public interface UpdateStreamRequestOrBuilder
*
*
*
- * Optional. Only validate the stream with the changes, without actually updating it.
- * The default is false.
+ * Optional. Only validate the stream with the changes, without actually
+ * updating it. The default is false.
*
*
* bool validate_only = 4 [(.google.api.field_behavior) = OPTIONAL];
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/proto/google/cloud/datastream/v1/datastream.proto b/java-datastream/proto-google-cloud-datastream-v1/src/main/proto/google/cloud/datastream/v1/datastream.proto
index cd9770794501..bf0b13f5e2a2 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/proto/google/cloud/datastream/v1/datastream.proto
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/proto/google/cloud/datastream/v1/datastream.proto
@@ -1,4 +1,4 @@
-// Copyright 2022 Google LLC
+// Copyright 2023 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
@@ -22,6 +22,7 @@ import "google/api/field_behavior.proto";
import "google/api/resource.proto";
import "google/cloud/datastream/v1/datastream_resources.proto";
import "google/longrunning/operations.proto";
+import "google/protobuf/empty.proto";
import "google/protobuf/field_mask.proto";
import "google/protobuf/timestamp.proto";
@@ -36,11 +37,13 @@ option ruby_package = "Google::Cloud::Datastream::V1";
// Datastream service
service Datastream {
option (google.api.default_host) = "datastream.googleapis.com";
- option (google.api.oauth_scopes) = "https://www.googleapis.com/auth/cloud-platform";
+ option (google.api.oauth_scopes) =
+ "https://www.googleapis.com/auth/cloud-platform";
// Use this method to list connection profiles created in a project and
// location.
- rpc ListConnectionProfiles(ListConnectionProfilesRequest) returns (ListConnectionProfilesResponse) {
+ rpc ListConnectionProfiles(ListConnectionProfilesRequest)
+ returns (ListConnectionProfilesResponse) {
option (google.api.http) = {
get: "/v1/{parent=projects/*/locations/*}/connectionProfiles"
};
@@ -48,7 +51,8 @@ service Datastream {
}
// Use this method to get details about a connection profile.
- rpc GetConnectionProfile(GetConnectionProfileRequest) returns (ConnectionProfile) {
+ rpc GetConnectionProfile(GetConnectionProfileRequest)
+ returns (ConnectionProfile) {
option (google.api.http) = {
get: "/v1/{name=projects/*/locations/*/connectionProfiles/*}"
};
@@ -56,12 +60,14 @@ service Datastream {
}
// Use this method to create a connection profile in a project and location.
- rpc CreateConnectionProfile(CreateConnectionProfileRequest) returns (google.longrunning.Operation) {
+ rpc CreateConnectionProfile(CreateConnectionProfileRequest)
+ returns (google.longrunning.Operation) {
option (google.api.http) = {
post: "/v1/{parent=projects/*/locations/*}/connectionProfiles"
body: "connection_profile"
};
- option (google.api.method_signature) = "parent,connection_profile,connection_profile_id";
+ option (google.api.method_signature) =
+ "parent,connection_profile,connection_profile_id";
option (google.longrunning.operation_info) = {
response_type: "ConnectionProfile"
metadata_type: "OperationMetadata"
@@ -69,7 +75,8 @@ service Datastream {
}
// Use this method to update the parameters of a connection profile.
- rpc UpdateConnectionProfile(UpdateConnectionProfileRequest) returns (google.longrunning.Operation) {
+ rpc UpdateConnectionProfile(UpdateConnectionProfileRequest)
+ returns (google.longrunning.Operation) {
option (google.api.http) = {
patch: "/v1/{connection_profile.name=projects/*/locations/*/connectionProfiles/*}"
body: "connection_profile"
@@ -82,7 +89,8 @@ service Datastream {
}
// Use this method to delete a connection profile.
- rpc DeleteConnectionProfile(DeleteConnectionProfileRequest) returns (google.longrunning.Operation) {
+ rpc DeleteConnectionProfile(DeleteConnectionProfileRequest)
+ returns (google.longrunning.Operation) {
option (google.api.http) = {
delete: "/v1/{name=projects/*/locations/*/connectionProfiles/*}"
};
@@ -97,7 +105,8 @@ service Datastream {
// The discover API call exposes the data objects and metadata belonging to
// the profile. Typically, a request returns children data objects of a
// parent data object that's optionally supplied in the request.
- rpc DiscoverConnectionProfile(DiscoverConnectionProfileRequest) returns (DiscoverConnectionProfileResponse) {
+ rpc DiscoverConnectionProfile(DiscoverConnectionProfileRequest)
+ returns (DiscoverConnectionProfileResponse) {
option (google.api.http) = {
post: "/v1/{parent=projects/*/locations/*}/connectionProfiles:discover"
body: "*"
@@ -175,7 +184,8 @@ service Datastream {
}
// Use this method to list the objects of a specific stream.
- rpc ListStreamObjects(ListStreamObjectsRequest) returns (ListStreamObjectsResponse) {
+ rpc ListStreamObjects(ListStreamObjectsRequest)
+ returns (ListStreamObjectsResponse) {
option (google.api.http) = {
get: "/v1/{parent=projects/*/locations/*/streams/*}/objects"
};
@@ -183,7 +193,8 @@ service Datastream {
}
// Use this method to start a backfill job for the specified stream object.
- rpc StartBackfillJob(StartBackfillJobRequest) returns (StartBackfillJobResponse) {
+ rpc StartBackfillJob(StartBackfillJobRequest)
+ returns (StartBackfillJobResponse) {
option (google.api.http) = {
post: "/v1/{object=projects/*/locations/*/streams/*/objects/*}:startBackfillJob"
body: "*"
@@ -192,7 +203,8 @@ service Datastream {
}
// Use this method to stop a backfill job for the specified stream object.
- rpc StopBackfillJob(StopBackfillJobRequest) returns (StopBackfillJobResponse) {
+ rpc StopBackfillJob(StopBackfillJobRequest)
+ returns (StopBackfillJobResponse) {
option (google.api.http) = {
post: "/v1/{object=projects/*/locations/*/streams/*/objects/*}:stopBackfillJob"
body: "*"
@@ -210,12 +222,14 @@ service Datastream {
}
// Use this method to create a private connectivity configuration.
- rpc CreatePrivateConnection(CreatePrivateConnectionRequest) returns (google.longrunning.Operation) {
+ rpc CreatePrivateConnection(CreatePrivateConnectionRequest)
+ returns (google.longrunning.Operation) {
option (google.api.http) = {
post: "/v1/{parent=projects/*/locations/*}/privateConnections"
body: "private_connection"
};
- option (google.api.method_signature) = "parent,private_connection,private_connection_id";
+ option (google.api.method_signature) =
+ "parent,private_connection,private_connection_id";
option (google.longrunning.operation_info) = {
response_type: "PrivateConnection"
metadata_type: "OperationMetadata"
@@ -223,7 +237,8 @@ service Datastream {
}
// Use this method to get details about a private connectivity configuration.
- rpc GetPrivateConnection(GetPrivateConnectionRequest) returns (PrivateConnection) {
+ rpc GetPrivateConnection(GetPrivateConnectionRequest)
+ returns (PrivateConnection) {
option (google.api.http) = {
get: "/v1/{name=projects/*/locations/*/privateConnections/*}"
};
@@ -232,7 +247,8 @@ service Datastream {
// Use this method to list private connectivity configurations in a project
// and location.
- rpc ListPrivateConnections(ListPrivateConnectionsRequest) returns (ListPrivateConnectionsResponse) {
+ rpc ListPrivateConnections(ListPrivateConnectionsRequest)
+ returns (ListPrivateConnectionsResponse) {
option (google.api.http) = {
get: "/v1/{parent=projects/*/locations/*}/privateConnections"
};
@@ -240,7 +256,8 @@ service Datastream {
}
// Use this method to delete a private connectivity configuration.
- rpc DeletePrivateConnection(DeletePrivateConnectionRequest) returns (google.longrunning.Operation) {
+ rpc DeletePrivateConnection(DeletePrivateConnectionRequest)
+ returns (google.longrunning.Operation) {
option (google.api.http) = {
delete: "/v1/{name=projects/*/locations/*/privateConnections/*}"
};
@@ -297,8 +314,8 @@ service Datastream {
// Request message for 'discover' ConnectionProfile request.
message DiscoverConnectionProfileRequest {
- // Required. The parent resource of the connection profile type. Must be in the
- // format `projects/*/locations/*`.
+ // Required. The parent resource of the connection profile type. Must be in
+ // the format `projects/*/locations/*`.
string parent = 1 [
(google.api.field_behavior) = REQUIRED,
(google.api.resource_reference) = {
@@ -355,8 +372,8 @@ message DiscoverConnectionProfileResponse {
// Request message for 'FetchStaticIps' request.
message FetchStaticIpsRequest {
- // Required. The resource name for the location for which static IPs should be returned.
- // Must be in the format `projects/*/locations/*`.
+ // Required. The resource name for the location for which static IPs should be
+ // returned. Must be in the format `projects/*/locations/*`.
string name = 1 [
(google.api.field_behavior) = REQUIRED,
(google.api.resource_reference) = {
@@ -449,7 +466,8 @@ message CreateConnectionProfileRequest {
string connection_profile_id = 2 [(google.api.field_behavior) = REQUIRED];
// Required. The connection profile resource to create.
- ConnectionProfile connection_profile = 3 [(google.api.field_behavior) = REQUIRED];
+ ConnectionProfile connection_profile = 3
+ [(google.api.field_behavior) = REQUIRED];
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
@@ -466,8 +484,8 @@ message CreateConnectionProfileRequest {
// not supported (00000000-0000-0000-0000-000000000000).
string request_id = 4 [(google.api.field_behavior) = OPTIONAL];
- // Optional. Only validate the connection profile, but don't create any resources.
- // The default is false.
+ // Optional. Only validate the connection profile, but don't create any
+ // resources. The default is false.
bool validate_only = 5 [(google.api.field_behavior) = OPTIONAL];
// Optional. Create the connection profile without validating it.
@@ -481,10 +499,12 @@ message UpdateConnectionProfileRequest {
// The fields specified in the update_mask are relative to the resource, not
// the full request. A field will be overwritten if it is in the mask. If the
// user does not provide a mask then all fields will be overwritten.
- google.protobuf.FieldMask update_mask = 1 [(google.api.field_behavior) = OPTIONAL];
+ google.protobuf.FieldMask update_mask = 1
+ [(google.api.field_behavior) = OPTIONAL];
// Required. The connection profile to update.
- ConnectionProfile connection_profile = 2 [(google.api.field_behavior) = REQUIRED];
+ ConnectionProfile connection_profile = 2
+ [(google.api.field_behavior) = REQUIRED];
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
@@ -501,8 +521,8 @@ message UpdateConnectionProfileRequest {
// not supported (00000000-0000-0000-0000-000000000000).
string request_id = 3 [(google.api.field_behavior) = OPTIONAL];
- // Optional. Only validate the connection profile, but don't update any resources.
- // The default is false.
+ // Optional. Only validate the connection profile, but don't update any
+ // resources. The default is false.
bool validate_only = 4 [(google.api.field_behavior) = OPTIONAL];
// Optional. Update the connection profile without validating it.
@@ -634,7 +654,8 @@ message UpdateStreamRequest {
// The fields specified in the update_mask are relative to the resource, not
// the full request. A field will be overwritten if it is in the mask. If the
// user does not provide a mask then all fields will be overwritten.
- google.protobuf.FieldMask update_mask = 1 [(google.api.field_behavior) = OPTIONAL];
+ google.protobuf.FieldMask update_mask = 1
+ [(google.api.field_behavior) = OPTIONAL];
// Required. The stream resource to update.
Stream stream = 2 [(google.api.field_behavior) = REQUIRED];
@@ -654,8 +675,8 @@ message UpdateStreamRequest {
// not supported (00000000-0000-0000-0000-000000000000).
string request_id = 3 [(google.api.field_behavior) = OPTIONAL];
- // Optional. Only validate the stream with the changes, without actually updating it.
- // The default is false.
+ // Optional. Only validate the stream with the changes, without actually
+ // updating it. The default is false.
bool validate_only = 4 [(google.api.field_behavior) = OPTIONAL];
// Optional. Update the stream without validating it.
@@ -711,12 +732,14 @@ message LookupStreamObjectRequest {
];
// Required. The source object identifier which maps to the stream object.
- SourceObjectIdentifier source_object_identifier = 2 [(google.api.field_behavior) = REQUIRED];
+ SourceObjectIdentifier source_object_identifier = 2
+ [(google.api.field_behavior) = REQUIRED];
}
// Request for manually initiating a backfill job for a specific stream object.
message StartBackfillJobRequest {
- // Required. The name of the stream object resource to start a backfill job for.
+ // Required. The name of the stream object resource to start a backfill job
+ // for.
string object = 1 [
(google.api.field_behavior) = REQUIRED,
(google.api.resource_reference) = {
@@ -734,7 +757,8 @@ message StartBackfillJobResponse {
// Request for manually stopping a running backfill job for a specific stream
// object.
message StopBackfillJobRequest {
- // Required. The name of the stream object resource to stop the backfill job for.
+ // Required. The name of the stream object resource to stop the backfill job
+ // for.
string object = 1 [
(google.api.field_behavior) = REQUIRED,
(google.api.resource_reference) = {
@@ -784,10 +808,12 @@ message ListStreamObjectsResponse {
// Represents the metadata of the long-running operation.
message OperationMetadata {
// Output only. The time the operation was created.
- google.protobuf.Timestamp create_time = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp create_time = 1
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The time the operation finished running.
- google.protobuf.Timestamp end_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp end_time = 2
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. Server-defined resource path for the target of the operation.
string target = 3 [(google.api.field_behavior) = OUTPUT_ONLY];
@@ -800,15 +826,17 @@ message OperationMetadata {
// Output only. Identifies whether the user has requested cancellation
// of the operation. Operations that have successfully been cancelled
- // have [Operation.error][] value with a [google.rpc.Status.code][google.rpc.Status.code] of 1,
- // corresponding to `Code.CANCELLED`.
+ // have [Operation.error][] value with a
+ // [google.rpc.Status.code][google.rpc.Status.code] of 1, corresponding to
+ // `Code.CANCELLED`.
bool requested_cancellation = 6 [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. API version used to start the operation.
string api_version = 7 [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. Results of executed validations if there are any.
- ValidationResult validation_result = 8 [(google.api.field_behavior) = OUTPUT_ONLY];
+ ValidationResult validation_result = 8
+ [(google.api.field_behavior) = OUTPUT_ONLY];
}
// Request for creating a private connection.
@@ -825,7 +853,8 @@ message CreatePrivateConnectionRequest {
string private_connection_id = 2 [(google.api.field_behavior) = REQUIRED];
// Required. The Private Connectivity resource to create.
- PrivateConnection private_connection = 3 [(google.api.field_behavior) = REQUIRED];
+ PrivateConnection private_connection = 3
+ [(google.api.field_behavior) = REQUIRED];
// Optional. A request ID to identify requests. Specify a unique request ID
// so that if you must retry your request, the server will know to ignore
@@ -841,11 +870,15 @@ message CreatePrivateConnectionRequest {
// The request ID must be a valid UUID with the exception that zero UUID is
// not supported (00000000-0000-0000-0000-000000000000).
string request_id = 4 [(google.api.field_behavior) = OPTIONAL];
+
+ // Optional. If set to true, will skip validations.
+ bool force = 6 [(google.api.field_behavior) = OPTIONAL];
}
// Request for listing private connections.
message ListPrivateConnectionsRequest {
- // Required. The parent that owns the collection of private connectivity configurations.
+ // Required. The parent that owns the collection of private connectivity
+ // configurations.
string parent = 1 [
(google.api.field_behavior) = REQUIRED,
(google.api.resource_reference) = {
@@ -912,8 +945,8 @@ message DeletePrivateConnectionRequest {
// not supported (00000000-0000-0000-0000-000000000000).
string request_id = 2 [(google.api.field_behavior) = OPTIONAL];
- // Optional. If set to true, any child routes that belong to this PrivateConnection will
- // also be deleted.
+ // Optional. If set to true, any child routes that belong to this
+ // PrivateConnection will also be deleted.
bool force = 3 [(google.api.field_behavior) = OPTIONAL];
}
diff --git a/java-datastream/proto-google-cloud-datastream-v1/src/main/proto/google/cloud/datastream/v1/datastream_resources.proto b/java-datastream/proto-google-cloud-datastream-v1/src/main/proto/google/cloud/datastream/v1/datastream_resources.proto
index 80a8deeaefbd..1007939dc8bc 100644
--- a/java-datastream/proto-google-cloud-datastream-v1/src/main/proto/google/cloud/datastream/v1/datastream_resources.proto
+++ b/java-datastream/proto-google-cloud-datastream-v1/src/main/proto/google/cloud/datastream/v1/datastream_resources.proto
@@ -1,4 +1,4 @@
-// Copyright 2022 Google LLC
+// Copyright 2023 Google LLC
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
@@ -103,14 +103,12 @@ message GcsProfile {
}
// BigQuery warehouse profile.
-message BigQueryProfile {
+message BigQueryProfile {}
-}
-
-// Static IP address connectivity.
-message StaticServiceIpConnectivity {
-
-}
+// Static IP address connectivity. Used when the source database is configured
+// to allow incoming connections from the Datastream public IP addresses
+// for the region specified in the connection profile.
+message StaticServiceIpConnectivity {}
// Forward SSH Tunnel connectivity.
message ForwardSshTunnelConnectivity {
@@ -181,10 +179,12 @@ message PrivateConnection {
string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The create time of the resource.
- google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp create_time = 2
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The update time of the resource.
- google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp update_time = 3
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Labels.
map labels = 4;
@@ -195,7 +195,8 @@ message PrivateConnection {
// Output only. The state of the Private Connection.
State state = 6 [(google.api.field_behavior) = OUTPUT_ONLY];
- // Output only. In case of error, the details of the error in a user-friendly format.
+ // Output only. In case of error, the details of the error in a user-friendly
+ // format.
Error error = 7 [(google.api.field_behavior) = OUTPUT_ONLY];
// VPC Peering Config.
@@ -226,10 +227,12 @@ message Route {
string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The create time of the resource.
- google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp create_time = 2
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The update time of the resource.
- google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp update_time = 3
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Labels.
map labels = 4;
@@ -262,8 +265,8 @@ message MysqlSslConfig {
// Output only. Indicates whether the client_certificate field is set.
bool client_certificate_set = 4 [(google.api.field_behavior) = OUTPUT_ONLY];
- // Input only. PEM-encoded certificate of the CA that signed the source database
- // server's certificate.
+ // Input only. PEM-encoded certificate of the CA that signed the source
+ // database server's certificate.
string ca_certificate = 5 [(google.api.field_behavior) = INPUT_ONLY];
// Output only. Indicates whether the ca_certificate field is set.
@@ -282,10 +285,12 @@ message ConnectionProfile {
string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The create time of the resource.
- google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp create_time = 2
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The update time of the resource.
- google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp update_time = 3
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Labels.
map labels = 4;
@@ -383,14 +388,10 @@ message OracleRdbms {
// Oracle data source configuration
message OracleSourceConfig {
// Configuration to drop large object values.
- message DropLargeObjects {
-
- }
+ message DropLargeObjects {}
// Configuration to stream large object values.
- message StreamLargeObjects {
-
- }
+ message StreamLargeObjects {}
// Oracle objects to include in the stream.
OracleRdbms include_objects = 1;
@@ -398,16 +399,20 @@ message OracleSourceConfig {
// Oracle objects to exclude from the stream.
OracleRdbms exclude_objects = 2;
- // Maximum number of concurrent CDC tasks. The number should be non negative.
- // If not set (or set to 0), the system's default value will be used.
+ // Maximum number of concurrent CDC tasks. The number should be non-negative.
+ // If not set (or set to 0), the system's default value is used.
int32 max_concurrent_cdc_tasks = 3;
+ // Maximum number of concurrent backfill tasks. The number should be
+ // non-negative. If not set (or set to 0), the system's default value is used.
+ int32 max_concurrent_backfill_tasks = 4;
+
// The configuration for handle Oracle large objects.
oneof large_objects_handling {
// Drop large object values.
DropLargeObjects drop_large_objects = 100;
- // Stream large object values.
+ // Stream large object values. NOTE: This feature is currently experimental.
StreamLargeObjects stream_large_objects = 102;
}
}
@@ -473,13 +478,21 @@ message PostgresqlSourceConfig {
// PostgreSQL objects to exclude from the stream.
PostgresqlRdbms exclude_objects = 2;
- // Required. The name of the logical replication slot that's configured with the
- // pgoutput plugin.
- string replication_slot = 3 [(google.api.field_behavior) = REQUIRED];
+ // Required. Immutable. The name of the logical replication slot that's
+ // configured with the pgoutput plugin.
+ string replication_slot = 3 [
+ (google.api.field_behavior) = REQUIRED,
+ (google.api.field_behavior) = IMMUTABLE
+ ];
- // Required. The name of the publication that includes the set of all tables that are
- // defined in the stream's include_objects.
+ // Required. The name of the publication that includes the set of all tables
+ // that are defined in the stream's include_objects.
string publication = 4 [(google.api.field_behavior) = REQUIRED];
+
+ // Maximum number of concurrent backfill tasks. The number should be non
+ // negative. If not set (or set to 0), the system's default value will be
+ // used.
+ int32 max_concurrent_backfill_tasks = 5;
}
// MySQL Column.
@@ -544,6 +557,11 @@ message MysqlSourceConfig {
// Maximum number of concurrent CDC tasks. The number should be non negative.
// If not set (or set to 0), the system's default value will be used.
int32 max_concurrent_cdc_tasks = 3;
+
+ // Maximum number of concurrent backfill tasks. The number should be non
+ // negative. If not set (or set to 0), the system's default value will be
+ // used.
+ int32 max_concurrent_backfill_tasks = 4;
}
// The configuration of the stream source.
@@ -571,9 +589,7 @@ message SourceConfig {
}
// AVRO file format configuration.
-message AvroFileFormat {
-
-}
+message AvroFileFormat {}
// JSON file format configuration.
message JsonFileFormat {
@@ -617,7 +633,8 @@ message GcsDestinationConfig {
int32 file_rotation_mb = 2;
// The maximum duration for which new events are added before a file is
- // closed and a new file is created.
+ // closed and a new file is created. Values within the range of 15-60 seconds
+ // are allowed.
google.protobuf.Duration file_rotation_interval = 3;
// File Format that the data should be written in.
@@ -630,9 +647,11 @@ message GcsDestinationConfig {
}
}
+// BigQuery destination configuration
message BigQueryDestinationConfig {
// A single target dataset to which all data will be streamed.
message SingleTargetDataset {
+ // The dataset ID of the target dataset.
string dataset_id = 1;
}
@@ -661,6 +680,7 @@ message BigQueryDestinationConfig {
string kms_key_name = 3;
}
+ // The dataset template to use for dynamic dataset creation.
DatasetTemplate dataset_template = 2;
}
@@ -759,18 +779,18 @@ message Stream {
}
// Backfill strategy to disable automatic backfill for the Stream's objects.
- message BackfillNoneStrategy {
-
- }
+ message BackfillNoneStrategy {}
// Output only. The stream's name.
string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The creation time of the stream.
- google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp create_time = 2
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The last update time of the stream.
- google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp update_time = 3
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Labels.
map labels = 4;
@@ -782,7 +802,8 @@ message Stream {
SourceConfig source_config = 6 [(google.api.field_behavior) = REQUIRED];
// Required. Destination connection profile configuration.
- DestinationConfig destination_config = 7 [(google.api.field_behavior) = REQUIRED];
+ DestinationConfig destination_config = 7
+ [(google.api.field_behavior) = REQUIRED];
// The state of the stream.
State state = 8;
@@ -804,7 +825,8 @@ message Stream {
// If provided, it will be used to encrypt the data.
// If left blank, data will be encrypted using an internal Stream-specific
// encryption key provisioned through KMS.
- optional string customer_managed_encryption_key = 10 [(google.api.field_behavior) = IMMUTABLE];
+ optional string customer_managed_encryption_key = 10
+ [(google.api.field_behavior) = IMMUTABLE];
}
// A specific stream object (e.g a specific DB table).
@@ -818,10 +840,12 @@ message StreamObject {
string name = 1 [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The creation time of the object.
- google.protobuf.Timestamp create_time = 2 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp create_time = 2
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. The last update time of the object.
- google.protobuf.Timestamp update_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp update_time = 3
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Required. Display name.
string display_name = 5 [(google.api.field_behavior) = REQUIRED];
@@ -930,10 +954,12 @@ message BackfillJob {
Trigger trigger = 2;
// Output only. Backfill job's start time.
- google.protobuf.Timestamp last_start_time = 3 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp last_start_time = 3
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. Backfill job's end time.
- google.protobuf.Timestamp last_end_time = 4 [(google.api.field_behavior) = OUTPUT_ONLY];
+ google.protobuf.Timestamp last_end_time = 4
+ [(google.api.field_behavior) = OUTPUT_ONLY];
// Output only. Errors which caused the backfill job to fail.
repeated Error errors = 5 [(google.api.field_behavior) = OUTPUT_ONLY];
diff --git a/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/AsyncCreatePrivateConnection.java b/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/AsyncCreatePrivateConnection.java
index 00754e7922f3..aed4113809ed 100644
--- a/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/AsyncCreatePrivateConnection.java
+++ b/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/AsyncCreatePrivateConnection.java
@@ -43,6 +43,7 @@ public static void asyncCreatePrivateConnection() throws Exception {
.setPrivateConnectionId("privateConnectionId-1926654532")
.setPrivateConnection(PrivateConnection.newBuilder().build())
.setRequestId("requestId693933066")
+ .setForce(true)
.build();
ApiFuture future =
datastreamClient.createPrivateConnectionCallable().futureCall(request);
diff --git a/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/AsyncCreatePrivateConnectionLRO.java b/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/AsyncCreatePrivateConnectionLRO.java
index cf9574f8bd5a..2fec769278fc 100644
--- a/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/AsyncCreatePrivateConnectionLRO.java
+++ b/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/AsyncCreatePrivateConnectionLRO.java
@@ -43,6 +43,7 @@ public static void asyncCreatePrivateConnectionLRO() throws Exception {
.setPrivateConnectionId("privateConnectionId-1926654532")
.setPrivateConnection(PrivateConnection.newBuilder().build())
.setRequestId("requestId693933066")
+ .setForce(true)
.build();
OperationFuture future =
datastreamClient.createPrivateConnectionOperationCallable().futureCall(request);
diff --git a/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/SyncCreatePrivateConnection.java b/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/SyncCreatePrivateConnection.java
index 61a4b6b69602..50f0c77c2d0a 100644
--- a/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/SyncCreatePrivateConnection.java
+++ b/java-datastream/samples/snippets/generated/com/google/cloud/datastream/v1/datastream/createprivateconnection/SyncCreatePrivateConnection.java
@@ -41,6 +41,7 @@ public static void syncCreatePrivateConnection() throws Exception {
.setPrivateConnectionId("privateConnectionId-1926654532")
.setPrivateConnection(PrivateConnection.newBuilder().build())
.setRequestId("requestId693933066")
+ .setForce(true)
.build();
PrivateConnection response = datastreamClient.createPrivateConnectionAsync(request).get();
}