diff --git a/java-data-fusion/google-cloud-data-fusion/src/main/java/com/google/cloud/datafusion/v1/DataFusionClient.java b/java-data-fusion/google-cloud-data-fusion/src/main/java/com/google/cloud/datafusion/v1/DataFusionClient.java
index 934194a318f6..bee49ee20640 100644
--- a/java-data-fusion/google-cloud-data-fusion/src/main/java/com/google/cloud/datafusion/v1/DataFusionClient.java
+++ b/java-data-fusion/google-cloud-data-fusion/src/main/java/com/google/cloud/datafusion/v1/DataFusionClient.java
@@ -18,6 +18,7 @@
 
 import com.google.api.core.ApiFuture;
 import com.google.api.core.ApiFutures;
+import com.google.api.core.BetaApi;
 import com.google.api.gax.core.BackgroundResource;
 import com.google.api.gax.httpjson.longrunning.OperationsClient;
 import com.google.api.gax.longrunning.OperationFuture;
@@ -190,6 +191,7 @@ public final com.google.longrunning.OperationsClient getOperationsClient() {
    * Returns the OperationsClient that can be used to query the status of a long-running operation
    * returned by another API method call.
    */
+  @BetaApi
   public final OperationsClient getHttpJsonOperationsClient() {
     return httpJsonOperationsClient;
   }
diff --git a/java-data-fusion/google-cloud-data-fusion/src/main/java/com/google/cloud/datafusion/v1beta1/DataFusionClient.java b/java-data-fusion/google-cloud-data-fusion/src/main/java/com/google/cloud/datafusion/v1beta1/DataFusionClient.java
index b243e91b1ef0..2ccdfb7f86e7 100644
--- a/java-data-fusion/google-cloud-data-fusion/src/main/java/com/google/cloud/datafusion/v1beta1/DataFusionClient.java
+++ b/java-data-fusion/google-cloud-data-fusion/src/main/java/com/google/cloud/datafusion/v1beta1/DataFusionClient.java
@@ -192,6 +192,7 @@ public final com.google.longrunning.OperationsClient getOperationsClient() {
    * Returns the OperationsClient that can be used to query the status of a long-running operation
    * returned by another API method call.
    */
+  @BetaApi
   public final OperationsClient getHttpJsonOperationsClient() {
     return httpJsonOperationsClient;
   }
diff --git a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstance.java b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstance.java
index 64e01bb0c6dc..542a7911bcdd 100644
--- a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstance.java
+++ b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstance.java
@@ -20,6 +20,7 @@
 import com.google.cloud.datafusion.v1.DataFusionClient;
 import com.google.cloud.datafusion.v1.DeleteInstanceRequest;
 import com.google.cloud.datafusion.v1.InstanceName;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteInstance {
 
diff --git a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstanceInstancename.java b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstanceInstancename.java
index 97cee12e15e3..00667e2c00bf 100644
--- a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstanceInstancename.java
+++ b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstanceInstancename.java
@@ -19,6 +19,7 @@
 // [START datafusion_v1_generated_datafusionclient_deleteinstance_instancename_sync]
 import com.google.cloud.datafusion.v1.DataFusionClient;
 import com.google.cloud.datafusion.v1.InstanceName;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteInstanceInstancename {
 
diff --git a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstanceString.java b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstanceString.java
index 7c2d0e7802ec..092371b0a256 100644
--- a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstanceString.java
+++ b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1/datafusionclient/deleteinstance/SyncDeleteInstanceString.java
@@ -19,6 +19,7 @@
 // [START datafusion_v1_generated_datafusionclient_deleteinstance_string_sync]
 import com.google.cloud.datafusion.v1.DataFusionClient;
 import com.google.cloud.datafusion.v1.InstanceName;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteInstanceString {
 
diff --git a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/createinstance/SyncCreateInstanceLocationnameInstanceString.java b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/createinstance/SyncCreateInstanceLocationnameInstanceString.java
index 383a2abf2681..4a9130ccc5b1 100644
--- a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/createinstance/SyncCreateInstanceLocationnameInstanceString.java
+++ b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/createinstance/SyncCreateInstanceLocationnameInstanceString.java
@@ -16,8 +16,7 @@
 
 package com.google.cloud.datafusion.v1beta1.samples;
 
-// [START
-// datafusion_v1beta1_generated_datafusionclient_createinstance_locationnameinstancestring_sync]
+// [START datafusion_v1beta1_generated_datafusionclient_createinstance_locationnameinstancestring_sync]
 import com.google.cloud.datafusion.v1beta1.DataFusionClient;
 import com.google.cloud.datafusion.v1beta1.Instance;
 import com.google.cloud.datafusion.v1beta1.LocationName;
@@ -39,5 +38,4 @@ public static void syncCreateInstanceLocationnameInstanceString() throws Excepti
     }
   }
 }
-// [END
-// datafusion_v1beta1_generated_datafusionclient_createinstance_locationnameinstancestring_sync]
+// [END datafusion_v1beta1_generated_datafusionclient_createinstance_locationnameinstancestring_sync]
diff --git a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstance.java b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstance.java
index 8b737f4e729a..8325f0834f64 100644
--- a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstance.java
+++ b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstance.java
@@ -20,6 +20,7 @@
 import com.google.cloud.datafusion.v1beta1.DataFusionClient;
 import com.google.cloud.datafusion.v1beta1.DeleteInstanceRequest;
 import com.google.cloud.datafusion.v1beta1.InstanceName;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteInstance {
 
diff --git a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstanceInstancename.java b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstanceInstancename.java
index c3c52946fe81..c400c0a362bb 100644
--- a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstanceInstancename.java
+++ b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstanceInstancename.java
@@ -19,6 +19,7 @@
 // [START datafusion_v1beta1_generated_datafusionclient_deleteinstance_instancename_sync]
 import com.google.cloud.datafusion.v1beta1.DataFusionClient;
 import com.google.cloud.datafusion.v1beta1.InstanceName;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteInstanceInstancename {
 
diff --git a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstanceString.java b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstanceString.java
index 56c6e1e505a2..809b70638941 100644
--- a/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstanceString.java
+++ b/java-data-fusion/samples/snippets/generated/com/google/cloud/datafusion/v1beta1/datafusionclient/deleteinstance/SyncDeleteInstanceString.java
@@ -19,6 +19,7 @@
 // [START datafusion_v1beta1_generated_datafusionclient_deleteinstance_string_sync]
 import com.google.cloud.datafusion.v1beta1.DataFusionClient;
 import com.google.cloud.datafusion.v1beta1.InstanceName;
+import com.google.protobuf.Empty;
 
 public class SyncDeleteInstanceString {