diff --git a/.github/readme/synth.metadata/synth.metadata b/.github/readme/synth.metadata/synth.metadata
index 26f8f854..7fc6132f 100644
--- a/.github/readme/synth.metadata/synth.metadata
+++ b/.github/readme/synth.metadata/synth.metadata
@@ -4,7 +4,7 @@
       "git": {
         "name": ".",
         "remote": "https://github.com/googleapis/java-bigqueryconnection.git",
-        "sha": "ac280253d3d30ef865268d611feee7aae545de7a"
+        "sha": "83fca1d125c83ba3d122ce44fcf671aa6d50e6bc"
       }
     },
     {
diff --git a/.github/workflows/auto-release.yaml b/.github/workflows/auto-release.yaml
index 2b6cdbc9..7c8816a7 100644
--- a/.github/workflows/auto-release.yaml
+++ b/.github/workflows/auto-release.yaml
@@ -4,7 +4,7 @@ name: auto-release
 jobs:
   approve:
     runs-on: ubuntu-latest
-    if: contains(github.head_ref, 'release-v')
+    if: contains(github.head_ref, 'release-please')
     steps:
     - uses: actions/github-script@v3
       with:
@@ -16,8 +16,8 @@ jobs:
             return;
           }
 
-          // only approve PRs like "chore: release <release version>"
-          if ( !context.payload.pull_request.title.startsWith("chore: release") ) {
+          // only approve PRs like "chore(master): release <release version>"
+          if ( !context.payload.pull_request.title.startsWith("chore(master): release") ) {
             return;
           }
 
diff --git a/.github/workflows/ci.yaml b/.github/workflows/ci.yaml
index 68302207..def8b3a2 100644
--- a/.github/workflows/ci.yaml
+++ b/.github/workflows/ci.yaml
@@ -54,7 +54,11 @@ jobs:
       with:
         java-version: 8
     - run: java -version
-    - run: .kokoro/linkage-monitor.sh
+    - name: Install artifacts to local Maven repository
+      run: .kokoro/build.sh
+      shell: bash
+    - name: Validate any conflicts with regard to com.google.cloud:libraries-bom (latest release)
+      uses: GoogleCloudPlatform/cloud-opensource-java/linkage-monitor@v1-linkagemonitor
   lint:
     runs-on: ubuntu-latest
     steps:
diff --git a/.kokoro/build.sh b/.kokoro/build.sh
index f9909c61..e140614d 100755
--- a/.kokoro/build.sh
+++ b/.kokoro/build.sh
@@ -119,8 +119,8 @@ bash .kokoro/coerce_logs.sh
 
 if [[ "${ENABLE_BUILD_COP}" == "true" ]]
 then
-    chmod +x ${KOKORO_GFILE_DIR}/linux_amd64/buildcop
-    ${KOKORO_GFILE_DIR}/linux_amd64/buildcop -repo=googleapis/java-bigqueryconnection
+    chmod +x ${KOKORO_GFILE_DIR}/linux_amd64/flakybot
+    ${KOKORO_GFILE_DIR}/linux_amd64/flakybot -repo=googleapis/java-bigqueryconnection
 fi
 
 echo "exiting with ${RETURN_CODE}"
diff --git a/.kokoro/dependencies.sh b/.kokoro/dependencies.sh
index c91e5a56..0fb8c843 100755
--- a/.kokoro/dependencies.sh
+++ b/.kokoro/dependencies.sh
@@ -31,7 +31,7 @@ export MAVEN_OPTS="-Xmx1024m -XX:MaxPermSize=128m"
 
 # this should run maven enforcer
 retry_with_backoff 3 10 \
-  mvn install -B -V \
+  mvn install -B -V -ntp \
     -DskipTests=true \
     -Dclirr.skip=true
 
@@ -86,4 +86,4 @@ then
 else
   msg "Errors found. See log statements above."
   exit 1
-fi
\ No newline at end of file
+fi
diff --git a/.kokoro/linkage-monitor.sh b/.kokoro/linkage-monitor.sh
deleted file mode 100755
index 759ab4e2..00000000
--- a/.kokoro/linkage-monitor.sh
+++ /dev/null
@@ -1,46 +0,0 @@
-#!/bin/bash
-# Copyright 2019 Google LLC
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#      http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-set -eo pipefail
-# Display commands being run.
-set -x
-
-## Get the directory of the build script
-scriptDir=$(realpath $(dirname "${BASH_SOURCE[0]}"))
-## cd to the parent directory, i.e. the root of the git repo
-cd ${scriptDir}/..
-
-# include common functions
-source ${scriptDir}/common.sh
-
-# Print out Java version
-java -version
-echo ${JOB_TYPE}
-
-# attempt to install 3 times with exponential backoff (starting with 10 seconds)
-retry_with_backoff 3 10 \
-  mvn install -B -V \
-    -DskipTests=true \
-    -Dclirr.skip=true \
-    -Denforcer.skip=true \
-    -Dmaven.javadoc.skip=true \
-    -Dgcloud.download.skip=true
-
-# Kokoro job cloud-opensource-java/ubuntu/linkage-monitor-gcs creates this JAR
-JAR=linkage-monitor-latest-all-deps.jar
-curl -v -O "https://storage.googleapis.com/cloud-opensource-java-linkage-monitor/${JAR}"
-
-# Fails if there's new linkage errors compared with baseline
-java -jar ${JAR} com.google.cloud:libraries-bom
diff --git a/.kokoro/release/publish_javadoc.cfg b/.kokoro/release/publish_javadoc.cfg
index 0f6e481b..c398416d 100644
--- a/.kokoro/release/publish_javadoc.cfg
+++ b/.kokoro/release/publish_javadoc.cfg
@@ -7,10 +7,10 @@ env_vars: {
   value: "docs-staging"
 }
 
+# cloud-rad staging
 env_vars: {
   key: "STAGING_BUCKET_V2"
-  value: "docs-staging-v2"
-  # Production will be at: docs-staging-v2
+  value: "docs-staging-v2-staging"
 }
 
 env_vars: {
@@ -26,4 +26,4 @@ before_action {
       keyname: "docuploader_service_account"
     }
   }
-}
+}
\ No newline at end of file
diff --git a/.kokoro/release/publish_javadoc.sh b/.kokoro/release/publish_javadoc.sh
index 5a972bba..c6af77ce 100755
--- a/.kokoro/release/publish_javadoc.sh
+++ b/.kokoro/release/publish_javadoc.sh
@@ -71,7 +71,7 @@ python3 -m docuploader create-metadata \
   --version ${VERSION} \
   --language java
 
-# upload docs
+# upload docs to staging bucket
 python3 -m docuploader upload . \
   --credentials ${CREDENTIALS} \
   --staging-bucket ${STAGING_BUCKET_V2}
diff --git a/.kokoro/release/publish_javadoc11.cfg b/.kokoro/release/publish_javadoc11.cfg
new file mode 100644
index 00000000..93a5c434
--- /dev/null
+++ b/.kokoro/release/publish_javadoc11.cfg
@@ -0,0 +1,30 @@
+# Format: //devtools/kokoro/config/proto/build.proto
+
+# cloud-rad production
+env_vars: {
+  key: "STAGING_BUCKET_V2"
+  value: "docs-staging-v2"
+}
+
+# Configure the docker image for kokoro-trampoline
+env_vars: {
+  key: "TRAMPOLINE_IMAGE"
+  value: "gcr.io/cloud-devrel-kokoro-resources/java11"
+}
+
+env_vars: {
+  key: "TRAMPOLINE_BUILD_FILE"
+  value: "github/java-bigqueryconnection/.kokoro/release/publish_javadoc11.sh"
+}
+
+before_action {
+  fetch_keystore {
+    keystore_resource {
+      keystore_config_id: 73713
+      keyname: "docuploader_service_account"
+    }
+  }
+}
+
+# Downloads docfx doclet resource. This will be in ${KOKORO_GFILE_DIR}/<doclet name>
+gfile_resources: "/bigstore/cloud-devrel-kokoro-resources/docfx"
diff --git a/.kokoro/release/publish_javadoc11.sh b/.kokoro/release/publish_javadoc11.sh
new file mode 100755
index 00000000..91992ea1
--- /dev/null
+++ b/.kokoro/release/publish_javadoc11.sh
@@ -0,0 +1,55 @@
+#!/bin/bash
+# Copyright 2021 Google Inc.
+#
+# Licensed under the Apache License, Version 2.0 (the "License");
+# you may not use this file except in compliance with the License.
+# You may obtain a copy of the License at
+#
+#      http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing, software
+# distributed under the License is distributed on an "AS IS" BASIS,
+# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+# See the License for the specific language governing permissions and
+# limitations under the License.
+
+set -eo pipefail
+
+if [[ -z "${CREDENTIALS}" ]]; then
+  CREDENTIALS=${KOKORO_KEYSTORE_DIR}/73713_docuploader_service_account
+fi
+
+if [[ -z "${STAGING_BUCKET_V2}" ]]; then
+  echo "Need to set STAGING_BUCKET_V2 environment variable"
+  exit 1
+fi
+
+# work from the git root directory
+pushd $(dirname "$0")/../../
+
+# install docuploader package
+python3 -m pip install gcp-docuploader
+
+# compile all packages
+mvn clean install -B -q -DskipTests=true
+
+export NAME=google-cloud-bigqueryconnection
+export VERSION=$(grep ${NAME}: versions.txt | cut -d: -f3)
+
+# V3 generates docfx yml from javadoc
+# generate yml
+mvn clean site -B -q -P docFX
+
+pushd target/docfx-yml
+
+# create metadata
+python3 -m docuploader create-metadata \
+ --name ${NAME} \
+ --version ${VERSION} \
+ --language java
+
+# upload yml to production bucket
+python3 -m docuploader upload . \
+ --credentials ${CREDENTIALS} \
+ --staging-bucket ${STAGING_BUCKET_V2} \
+ --destination-prefix docfx-
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 80a8aa0e..3fd63753 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,5 +1,19 @@
 # Changelog
 
+### [1.0.9](https://www.github.com/googleapis/java-bigqueryconnection/compare/v1.0.8...v1.0.9) (2021-02-23)
+
+
+### Documentation
+
+* generate sample code in the Java microgenerator ([#300](https://www.github.com/googleapis/java-bigqueryconnection/issues/300)) ([3980794](https://www.github.com/googleapis/java-bigqueryconnection/commit/3980794301b44ea51c90385aa9fb8ea3ee5444cd))
+
+
+### Dependencies
+
+* update dependency com.google.cloud:google-cloud-shared-dependencies to v0.19.0 ([#310](https://www.github.com/googleapis/java-bigqueryconnection/issues/310)) ([98ee3cf](https://www.github.com/googleapis/java-bigqueryconnection/commit/98ee3cf4a022efaf53ad0d29a96ae68509ac5232))
+* update dependency com.google.protobuf:protobuf-java-util to v3.15.0 ([#308](https://www.github.com/googleapis/java-bigqueryconnection/issues/308)) ([1af206a](https://www.github.com/googleapis/java-bigqueryconnection/commit/1af206abf6f9de6efd0faf65604d199c7321949e))
+* update dependency com.google.protobuf:protobuf-java-util to v3.15.1 ([#311](https://www.github.com/googleapis/java-bigqueryconnection/issues/311)) ([cc53329](https://www.github.com/googleapis/java-bigqueryconnection/commit/cc53329ba117aab63cb22e19e65c0ce3785003f9))
+
 ### [1.0.8](https://www.github.com/googleapis/java-bigqueryconnection/compare/v1.0.7...v1.0.8) (2021-01-14)
 
 
diff --git a/LICENSE b/LICENSE
index d6456956..261eeb9e 100644
--- a/LICENSE
+++ b/LICENSE
@@ -1,4 +1,3 @@
-
                                  Apache License
                            Version 2.0, January 2004
                         http://www.apache.org/licenses/
diff --git a/README.md b/README.md
index f15fffb5..2550c780 100644
--- a/README.md
+++ b/README.md
@@ -17,19 +17,19 @@ If you are using Maven, add this to your pom.xml file:
 <dependency>
   <groupId>com.google.cloud</groupId>
   <artifactId>google-cloud-bigqueryconnection</artifactId>
-  <version>1.0.7</version>
+  <version>1.0.8</version>
 </dependency>
 
 ```
 
 If you are using Gradle without BOM, add this to your dependencies
 ```Groovy
-compile 'com.google.cloud:google-cloud-bigqueryconnection:1.0.7'
+compile 'com.google.cloud:google-cloud-bigqueryconnection:1.0.8'
 ```
 
 If you are using SBT, add this to your dependencies
 ```Scala
-libraryDependencies += "com.google.cloud" % "google-cloud-bigqueryconnection" % "1.0.7"
+libraryDependencies += "com.google.cloud" % "google-cloud-bigqueryconnection" % "1.0.8"
 ```
 
 ## Authentication
diff --git a/google-cloud-bigqueryconnection-bom/pom.xml b/google-cloud-bigqueryconnection-bom/pom.xml
index bc8bb4ed..c7059fd0 100644
--- a/google-cloud-bigqueryconnection-bom/pom.xml
+++ b/google-cloud-bigqueryconnection-bom/pom.xml
@@ -3,12 +3,12 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.google.cloud</groupId>
   <artifactId>google-cloud-bigqueryconnection-bom</artifactId>
-  <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+  <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
   <packaging>pom</packaging>
   <parent>
     <groupId>com.google.cloud</groupId>
     <artifactId>google-cloud-shared-config</artifactId>
-    <version>0.9.4</version>
+    <version>0.10.0</version>
   </parent>
 
   <name>Google Cloud BigQuery Connections BOM</name>
@@ -42,11 +42,11 @@
   <distributionManagement>
     <snapshotRepository>
       <id>sonatype-nexus-snapshots</id>
-      <url>https://oss.sonatype.org/content/repositories/snapshots</url>
+      <url>https://google.oss.sonatype.org/content/repositories/snapshots</url>
     </snapshotRepository>
     <repository>
       <id>sonatype-nexus-staging</id>
-      <url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url>
+      <url>https://google.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
     </repository>
   </distributionManagement>
 
@@ -64,27 +64,27 @@
       <dependency>
         <groupId>com.google.cloud</groupId>
         <artifactId>google-cloud-bigqueryconnection</artifactId>
-        <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+        <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
       </dependency>
       <dependency>
         <groupId>com.google.api.grpc</groupId>
         <artifactId>proto-google-cloud-bigqueryconnection-v1</artifactId>
-        <version>1.0.8</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1:current} -->
+        <version>1.0.9</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1:current} -->
       </dependency>
       <dependency>
         <groupId>com.google.api.grpc</groupId>
         <artifactId>grpc-google-cloud-bigqueryconnection-v1</artifactId>
-        <version>1.0.8</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1:current} -->
+        <version>1.0.9</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1:current} -->
       </dependency>
       <dependency>
         <groupId>com.google.api.grpc</groupId>
         <artifactId>proto-google-cloud-bigqueryconnection-v1beta1</artifactId>
-        <version>0.5.8</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1beta1:current} -->
+        <version>0.5.9</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1beta1:current} -->
       </dependency>
       <dependency>
         <groupId>com.google.api.grpc</groupId>
         <artifactId>grpc-google-cloud-bigqueryconnection-v1beta1</artifactId>
-        <version>0.5.8</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1beta1:current} -->
+        <version>0.5.9</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1beta1:current} -->
       </dependency>
     </dependencies>
   </dependencyManagement>
@@ -98,6 +98,18 @@
           <skip>true</skip>
         </configuration>
       </plugin>
+      <plugin>
+        <groupId>org.sonatype.plugins</groupId>
+        <artifactId>nexus-staging-maven-plugin</artifactId>
+        <version>1.6.8</version>
+        <extensions>true</extensions>
+        <configuration>
+          <serverId>ossrh</serverId>
+          <nexusUrl>https://google.oss.sonatype.org/</nexusUrl>
+          <autoReleaseAfterClose>false</autoReleaseAfterClose>
+          <stagingProgressTimeoutMinutes>15</stagingProgressTimeoutMinutes>
+        </configuration>
+      </plugin>
     </plugins>
   </build>
 </project>
diff --git a/google-cloud-bigqueryconnection/pom.xml b/google-cloud-bigqueryconnection/pom.xml
index 57172dbd..079cd6e0 100644
--- a/google-cloud-bigqueryconnection/pom.xml
+++ b/google-cloud-bigqueryconnection/pom.xml
@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.google.cloud</groupId>
   <artifactId>google-cloud-bigqueryconnection</artifactId>
-  <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+  <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
   <packaging>jar</packaging>
   <name>Google Cloud BigQuery Connections</name>
   <url>https://github.com/googleapis/java-bigqueryconnection</url>
@@ -11,7 +11,7 @@
   <parent>
     <groupId>com.google.cloud</groupId>
     <artifactId>google-cloud-bigqueryconnection-parent</artifactId>
-    <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+    <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
   </parent>
   <properties>
     <site.installationModule>google-cloud-bigqueryconnection</site.installationModule>
diff --git a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/ConnectionServiceClient.java b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/ConnectionServiceClient.java
index 2eb9440a..169448af 100644
--- a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/ConnectionServiceClient.java
+++ b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/ConnectionServiceClient.java
@@ -43,6 +43,16 @@
  * <p>This class provides the ability to make remote calls to the backing service through method
  * calls that map to API methods. Sample code to get started:
  *
+ * <pre>{@code
+ * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+ *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ *   ConnectionProto.Connection connection = ConnectionProto.Connection.newBuilder().build();
+ *   String connectionId = "connectionId1923106969";
+ *   ConnectionProto.Connection response =
+ *       connectionServiceClient.createConnection(parent, connection, connectionId);
+ * }
+ * }</pre>
+ *
  * <p>Note: close() needs to be called on the ConnectionServiceClient object to clean up resources
  * such as threads. In the example above, try-with-resources is used, which automatically calls
  * close().
@@ -150,6 +160,18 @@ public ConnectionServiceStub getStub() {
   /**
    * Creates a new connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   ConnectionProto.Connection connection = ConnectionProto.Connection.newBuilder().build();
+   *   String connectionId = "connectionId1923106969";
+   *   ConnectionProto.Connection response =
+   *       connectionServiceClient.createConnection(parent, connection, connectionId);
+   * }
+   * }</pre>
+   *
    * @param parent Required. Parent resource name. Must be in the format
    *     `projects/{project_id}/locations/{location_id}`
    * @param connection Required. Connection to create.
@@ -171,6 +193,18 @@ public final ConnectionProto.Connection createConnection(
   /**
    * Creates a new connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+   *   ConnectionProto.Connection connection = ConnectionProto.Connection.newBuilder().build();
+   *   String connectionId = "connectionId1923106969";
+   *   ConnectionProto.Connection response =
+   *       connectionServiceClient.createConnection(parent, connection, connectionId);
+   * }
+   * }</pre>
+   *
    * @param parent Required. Parent resource name. Must be in the format
    *     `projects/{project_id}/locations/{location_id}`
    * @param connection Required. Connection to create.
@@ -192,6 +226,19 @@ public final ConnectionProto.Connection createConnection(
   /**
    * Creates a new connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.CreateConnectionRequest request =
+   *       ConnectionProto.CreateConnectionRequest.newBuilder()
+   *           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+   *           .setConnectionId("connectionId1923106969")
+   *           .build();
+   *   ConnectionProto.Connection response = connectionServiceClient.createConnection(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -205,6 +252,20 @@ public final ConnectionProto.Connection createConnection(
    * Creates a new connection.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.CreateConnectionRequest request =
+   *       ConnectionProto.CreateConnectionRequest.newBuilder()
+   *           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+   *           .setConnectionId("connectionId1923106969")
+   *           .build();
+   *   ApiFuture<ConnectionProto.Connection> future =
+   *       connectionServiceClient.createConnectionCallable().futureCall(request);
+   *   // Do something.
+   *   ConnectionProto.Connection response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<ConnectionProto.CreateConnectionRequest, ConnectionProto.Connection>
       createConnectionCallable() {
@@ -215,6 +276,15 @@ public final ConnectionProto.Connection createConnection(
   /**
    * Returns specified connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionName name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   ConnectionProto.Connection response = connectionServiceClient.getConnection(name);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the requested connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -231,6 +301,15 @@ public final ConnectionProto.Connection getConnection(ConnectionName name) {
   /**
    * Returns specified connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   ConnectionProto.Connection response = connectionServiceClient.getConnection(name);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the requested connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -245,6 +324,18 @@ public final ConnectionProto.Connection getConnection(String name) {
   /**
    * Returns specified connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.GetConnectionRequest request =
+   *       ConnectionProto.GetConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .build();
+   *   ConnectionProto.Connection response = connectionServiceClient.getConnection(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -258,6 +349,19 @@ public final ConnectionProto.Connection getConnection(
    * Returns specified connection.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.GetConnectionRequest request =
+   *       ConnectionProto.GetConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .build();
+   *   ApiFuture<ConnectionProto.Connection> future =
+   *       connectionServiceClient.getConnectionCallable().futureCall(request);
+   *   // Do something.
+   *   ConnectionProto.Connection response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<ConnectionProto.GetConnectionRequest, ConnectionProto.Connection>
       getConnectionCallable() {
@@ -268,6 +372,17 @@ public final ConnectionProto.Connection getConnection(
   /**
    * Returns a list of connections in the given project.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   UInt32Value maxResults = UInt32Value.newBuilder().build();
+   *   ConnectionProto.ListConnectionsResponse response =
+   *       connectionServiceClient.listConnections(parent, maxResults);
+   * }
+   * }</pre>
+   *
    * @param parent Required. Parent resource name. Must be in the form:
    *     `projects/{project_id}/locations/{location_id}`
    * @param maxResults Required. Maximum number of results per page.
@@ -287,6 +402,17 @@ public final ConnectionProto.ListConnectionsResponse listConnections(
   /**
    * Returns a list of connections in the given project.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+   *   UInt32Value maxResults = UInt32Value.newBuilder().build();
+   *   ConnectionProto.ListConnectionsResponse response =
+   *       connectionServiceClient.listConnections(parent, maxResults);
+   * }
+   * }</pre>
+   *
    * @param parent Required. Parent resource name. Must be in the form:
    *     `projects/{project_id}/locations/{location_id}`
    * @param maxResults Required. Maximum number of results per page.
@@ -306,6 +432,21 @@ public final ConnectionProto.ListConnectionsResponse listConnections(
   /**
    * Returns a list of connections in the given project.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.ListConnectionsRequest request =
+   *       ConnectionProto.ListConnectionsRequest.newBuilder()
+   *           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+   *           .setMaxResults(UInt32Value.newBuilder().build())
+   *           .setPageToken("pageToken873572522")
+   *           .build();
+   *   ConnectionProto.ListConnectionsResponse response =
+   *       connectionServiceClient.listConnections(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -319,6 +460,21 @@ public final ConnectionProto.ListConnectionsResponse listConnections(
    * Returns a list of connections in the given project.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.ListConnectionsRequest request =
+   *       ConnectionProto.ListConnectionsRequest.newBuilder()
+   *           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+   *           .setMaxResults(UInt32Value.newBuilder().build())
+   *           .setPageToken("pageToken873572522")
+   *           .build();
+   *   ApiFuture<ConnectionProto.ListConnectionsResponse> future =
+   *       connectionServiceClient.listConnectionsCallable().futureCall(request);
+   *   // Do something.
+   *   ConnectionProto.ListConnectionsResponse response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<
           ConnectionProto.ListConnectionsRequest, ConnectionProto.ListConnectionsResponse>
@@ -331,6 +487,18 @@ public final ConnectionProto.ListConnectionsResponse listConnections(
    * Updates the specified connection. For security reasons, also resets credential if connection
    * properties are in the update field mask.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionName name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   ConnectionProto.Connection connection = ConnectionProto.Connection.newBuilder().build();
+   *   FieldMask updateMask = FieldMask.newBuilder().build();
+   *   ConnectionProto.Connection response =
+   *       connectionServiceClient.updateConnection(name, connection, updateMask);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the connection to update, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @param connection Required. Connection containing the updated fields.
@@ -353,6 +521,18 @@ public final ConnectionProto.Connection updateConnection(
    * Updates the specified connection. For security reasons, also resets credential if connection
    * properties are in the update field mask.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   ConnectionProto.Connection connection = ConnectionProto.Connection.newBuilder().build();
+   *   FieldMask updateMask = FieldMask.newBuilder().build();
+   *   ConnectionProto.Connection response =
+   *       connectionServiceClient.updateConnection(name, connection, updateMask);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the connection to update, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @param connection Required. Connection containing the updated fields.
@@ -375,6 +555,19 @@ public final ConnectionProto.Connection updateConnection(
    * Updates the specified connection. For security reasons, also resets credential if connection
    * properties are in the update field mask.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.UpdateConnectionRequest request =
+   *       ConnectionProto.UpdateConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setUpdateMask(FieldMask.newBuilder().build())
+   *           .build();
+   *   ConnectionProto.Connection response = connectionServiceClient.updateConnection(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -389,6 +582,20 @@ public final ConnectionProto.Connection updateConnection(
    * properties are in the update field mask.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.UpdateConnectionRequest request =
+   *       ConnectionProto.UpdateConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setUpdateMask(FieldMask.newBuilder().build())
+   *           .build();
+   *   ApiFuture<ConnectionProto.Connection> future =
+   *       connectionServiceClient.updateConnectionCallable().futureCall(request);
+   *   // Do something.
+   *   ConnectionProto.Connection response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<ConnectionProto.UpdateConnectionRequest, ConnectionProto.Connection>
       updateConnectionCallable() {
@@ -399,6 +606,17 @@ public final ConnectionProto.Connection updateConnection(
   /**
    * Sets the credential for the specified connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String name = "name3373707";
+   *   ConnectionProto.ConnectionCredential credential =
+   *       ConnectionProto.ConnectionCredential.newBuilder().build();
+   *   connectionServiceClient.updateConnectionCredential(name, credential);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}/credential`
    * @param credential Required. Credential to use with the connection.
@@ -418,6 +636,18 @@ public final void updateConnectionCredential(
   /**
    * Sets the credential for the specified connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.UpdateConnectionCredentialRequest request =
+   *       ConnectionProto.UpdateConnectionCredentialRequest.newBuilder()
+   *           .setName("name3373707")
+   *           .build();
+   *   connectionServiceClient.updateConnectionCredential(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -431,6 +661,19 @@ public final void updateConnectionCredential(
    * Sets the credential for the specified connection.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.UpdateConnectionCredentialRequest request =
+   *       ConnectionProto.UpdateConnectionCredentialRequest.newBuilder()
+   *           .setName("name3373707")
+   *           .build();
+   *   ApiFuture<Empty> future =
+   *       connectionServiceClient.updateConnectionCredentialCallable().futureCall(request);
+   *   // Do something.
+   *   future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<ConnectionProto.UpdateConnectionCredentialRequest, Empty>
       updateConnectionCredentialCallable() {
@@ -441,6 +684,15 @@ public final void updateConnectionCredential(
   /**
    * Deletes connection and associated credential.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionName name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   connectionServiceClient.deleteConnection(name);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the deleted connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -457,6 +709,15 @@ public final void deleteConnection(ConnectionName name) {
   /**
    * Deletes connection and associated credential.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   connectionServiceClient.deleteConnection(name);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the deleted connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -471,6 +732,18 @@ public final void deleteConnection(String name) {
   /**
    * Deletes connection and associated credential.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.DeleteConnectionRequest request =
+   *       ConnectionProto.DeleteConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .build();
+   *   connectionServiceClient.deleteConnection(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -483,6 +756,19 @@ public final void deleteConnection(ConnectionProto.DeleteConnectionRequest reque
    * Deletes connection and associated credential.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionProto.DeleteConnectionRequest request =
+   *       ConnectionProto.DeleteConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .build();
+   *   ApiFuture<Empty> future =
+   *       connectionServiceClient.deleteConnectionCallable().futureCall(request);
+   *   // Do something.
+   *   future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<ConnectionProto.DeleteConnectionRequest, Empty>
       deleteConnectionCallable() {
@@ -494,6 +780,16 @@ public final void deleteConnection(ConnectionProto.DeleteConnectionRequest reque
    * Gets the access control policy for a resource. Returns an empty policy if the resource exists
    * and does not have a policy set.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ResourceName resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   GetPolicyOptions options = GetPolicyOptions.newBuilder().build();
+   *   Policy response = connectionServiceClient.getIamPolicy(resource, options);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy is being requested. See the
    *     operation documentation for the appropriate value for this field.
    * @param options OPTIONAL: A `GetPolicyOptions` object for specifying options to `GetIamPolicy`.
@@ -514,6 +810,16 @@ public final Policy getIamPolicy(ResourceName resource, GetPolicyOptions options
    * Gets the access control policy for a resource. Returns an empty policy if the resource exists
    * and does not have a policy set.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   GetPolicyOptions options = GetPolicyOptions.newBuilder().build();
+   *   Policy response = connectionServiceClient.getIamPolicy(resource, options);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy is being requested. See the
    *     operation documentation for the appropriate value for this field.
    * @param options OPTIONAL: A `GetPolicyOptions` object for specifying options to `GetIamPolicy`.
@@ -531,6 +837,19 @@ public final Policy getIamPolicy(String resource, GetPolicyOptions options) {
    * Gets the access control policy for a resource. Returns an empty policy if the resource exists
    * and does not have a policy set.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   GetIamPolicyRequest request =
+   *       GetIamPolicyRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setOptions(GetPolicyOptions.newBuilder().build())
+   *           .build();
+   *   Policy response = connectionServiceClient.getIamPolicy(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -544,6 +863,19 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) {
    * and does not have a policy set.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   GetIamPolicyRequest request =
+   *       GetIamPolicyRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setOptions(GetPolicyOptions.newBuilder().build())
+   *           .build();
+   *   ApiFuture<Policy> future = connectionServiceClient.getIamPolicyCallable().futureCall(request);
+   *   // Do something.
+   *   Policy response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
     return stub.getIamPolicyCallable();
@@ -555,6 +887,16 @@ public final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
    *
    * <p>Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ResourceName resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   Policy policy = Policy.newBuilder().build();
+   *   Policy response = connectionServiceClient.setIamPolicy(resource, policy);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy is being specified. See the
    *     operation documentation for the appropriate value for this field.
    * @param policy REQUIRED: The complete policy to be applied to the `resource`. The size of the
@@ -577,6 +919,16 @@ public final Policy setIamPolicy(ResourceName resource, Policy policy) {
    *
    * <p>Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   Policy policy = Policy.newBuilder().build();
+   *   Policy response = connectionServiceClient.setIamPolicy(resource, policy);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy is being specified. See the
    *     operation documentation for the appropriate value for this field.
    * @param policy REQUIRED: The complete policy to be applied to the `resource`. The size of the
@@ -596,6 +948,19 @@ public final Policy setIamPolicy(String resource, Policy policy) {
    *
    * <p>Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   SetIamPolicyRequest request =
+   *       SetIamPolicyRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setPolicy(Policy.newBuilder().build())
+   *           .build();
+   *   Policy response = connectionServiceClient.setIamPolicy(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -610,6 +975,19 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {
    * <p>Can return Public Errors: NOT_FOUND, INVALID_ARGUMENT and PERMISSION_DENIED
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   SetIamPolicyRequest request =
+   *       SetIamPolicyRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setPolicy(Policy.newBuilder().build())
+   *           .build();
+   *   ApiFuture<Policy> future = connectionServiceClient.setIamPolicyCallable().futureCall(request);
+   *   // Do something.
+   *   Policy response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {
     return stub.setIamPolicyCallable();
@@ -624,6 +1002,17 @@ public final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {
    * command-line tools, not for authorization checking. This operation may "fail open" without
    * warning.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ResourceName resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   List<String> permissions = new ArrayList<>();
+   *   TestIamPermissionsResponse response =
+   *       connectionServiceClient.testIamPermissions(resource, permissions);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy detail is being requested. See the
    *     operation documentation for the appropriate value for this field.
    * @param permissions The set of permissions to check for the `resource`. Permissions with
@@ -650,6 +1039,17 @@ public final TestIamPermissionsResponse testIamPermissions(
    * command-line tools, not for authorization checking. This operation may "fail open" without
    * warning.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   List<String> permissions = new ArrayList<>();
+   *   TestIamPermissionsResponse response =
+   *       connectionServiceClient.testIamPermissions(resource, permissions);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy detail is being requested. See the
    *     operation documentation for the appropriate value for this field.
    * @param permissions The set of permissions to check for the `resource`. Permissions with
@@ -676,6 +1076,19 @@ public final TestIamPermissionsResponse testIamPermissions(
    * command-line tools, not for authorization checking. This operation may "fail open" without
    * warning.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   TestIamPermissionsRequest request =
+   *       TestIamPermissionsRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .addAllPermissions(new ArrayList<String>())
+   *           .build();
+   *   TestIamPermissionsResponse response = connectionServiceClient.testIamPermissions(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -693,6 +1106,20 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq
    * warning.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   TestIamPermissionsRequest request =
+   *       TestIamPermissionsRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .addAllPermissions(new ArrayList<String>())
+   *           .build();
+   *   ApiFuture<TestIamPermissionsResponse> future =
+   *       connectionServiceClient.testIamPermissionsCallable().futureCall(request);
+   *   // Do something.
+   *   TestIamPermissionsResponse response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<TestIamPermissionsRequest, TestIamPermissionsResponse>
       testIamPermissionsCallable() {
diff --git a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/gapic_metadata.json b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/gapic_metadata.json
new file mode 100644
index 00000000..22a816a2
--- /dev/null
+++ b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/gapic_metadata.json
@@ -0,0 +1,45 @@
+{
+  "schema": "1.0",
+  "comment": "This file maps proto services/RPCs to the corresponding library clients/methods",
+  "language": "java",
+  "protoPackage": "google.cloud.bigquery.connection.v1beta1",
+  "libraryPackage": "com.google.cloud.bigquery.connection.v1beta1",
+  "services": {
+    "ConnectionService": {
+      "clients": {
+        "grpc": {
+          "libraryClient": "ConnectionServiceClient",
+          "rpcs": {
+            "CreateConnection": {
+              "methods": ["createConnection", "createConnection", "createConnection", "createConnectionCallable"]
+            },
+            "DeleteConnection": {
+              "methods": ["deleteConnection", "deleteConnection", "deleteConnection", "deleteConnectionCallable"]
+            },
+            "GetConnection": {
+              "methods": ["getConnection", "getConnection", "getConnection", "getConnectionCallable"]
+            },
+            "GetIamPolicy": {
+              "methods": ["getIamPolicy", "getIamPolicy", "getIamPolicy", "getIamPolicyCallable"]
+            },
+            "ListConnections": {
+              "methods": ["listConnections", "listConnections", "listConnections", "listConnectionsCallable"]
+            },
+            "SetIamPolicy": {
+              "methods": ["setIamPolicy", "setIamPolicy", "setIamPolicy", "setIamPolicyCallable"]
+            },
+            "TestIamPermissions": {
+              "methods": ["testIamPermissions", "testIamPermissions", "testIamPermissions", "testIamPermissionsCallable"]
+            },
+            "UpdateConnection": {
+              "methods": ["updateConnection", "updateConnection", "updateConnection", "updateConnectionCallable"]
+            },
+            "UpdateConnectionCredential": {
+              "methods": ["updateConnectionCredential", "updateConnectionCredential", "updateConnectionCredentialCallable"]
+            }
+          }
+        }
+      }
+    }
+  }
+}
\ No newline at end of file
diff --git a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/package-info.java b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/package-info.java
index d1b53c92..2a693a61 100644
--- a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/package-info.java
+++ b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/package-info.java
@@ -22,6 +22,16 @@
  * <p>Service Description: Manages external data source connections and credentials.
  *
  * <p>Sample for ConnectionServiceClient:
+ *
+ * <pre>{@code
+ * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+ *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ *   ConnectionProto.Connection connection = ConnectionProto.Connection.newBuilder().build();
+ *   String connectionId = "connectionId1923106969";
+ *   ConnectionProto.Connection response =
+ *       connectionServiceClient.createConnection(parent, connection, connectionId);
+ * }
+ * }</pre>
  */
 @Generated("by gapic-generator-java")
 package com.google.cloud.bigquery.connection.v1beta1;
diff --git a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/stub/GrpcConnectionServiceStub.java b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/stub/GrpcConnectionServiceStub.java
index c6a21b01..ed724cd4 100644
--- a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/stub/GrpcConnectionServiceStub.java
+++ b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/stub/GrpcConnectionServiceStub.java
@@ -404,44 +404,53 @@ public GrpcOperationsStub getOperationsStub() {
     return operationsStub;
   }
 
+  @Override
   public UnaryCallable<ConnectionProto.CreateConnectionRequest, ConnectionProto.Connection>
       createConnectionCallable() {
     return createConnectionCallable;
   }
 
+  @Override
   public UnaryCallable<ConnectionProto.GetConnectionRequest, ConnectionProto.Connection>
       getConnectionCallable() {
     return getConnectionCallable;
   }
 
+  @Override
   public UnaryCallable<
           ConnectionProto.ListConnectionsRequest, ConnectionProto.ListConnectionsResponse>
       listConnectionsCallable() {
     return listConnectionsCallable;
   }
 
+  @Override
   public UnaryCallable<ConnectionProto.UpdateConnectionRequest, ConnectionProto.Connection>
       updateConnectionCallable() {
     return updateConnectionCallable;
   }
 
+  @Override
   public UnaryCallable<ConnectionProto.UpdateConnectionCredentialRequest, Empty>
       updateConnectionCredentialCallable() {
     return updateConnectionCredentialCallable;
   }
 
+  @Override
   public UnaryCallable<ConnectionProto.DeleteConnectionRequest, Empty> deleteConnectionCallable() {
     return deleteConnectionCallable;
   }
 
+  @Override
   public UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
     return getIamPolicyCallable;
   }
 
+  @Override
   public UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {
     return setIamPolicyCallable;
   }
 
+  @Override
   public UnaryCallable<TestIamPermissionsRequest, TestIamPermissionsResponse>
       testIamPermissionsCallable() {
     return testIamPermissionsCallable;
diff --git a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/ConnectionServiceClient.java b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/ConnectionServiceClient.java
index f2c98c42..10f0361b 100644
--- a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/ConnectionServiceClient.java
+++ b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/ConnectionServiceClient.java
@@ -59,6 +59,16 @@
  * <p>This class provides the ability to make remote calls to the backing service through method
  * calls that map to API methods. Sample code to get started:
  *
+ * <pre>{@code
+ * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+ *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ *   Connection connection = Connection.newBuilder().build();
+ *   String connectionId = "connectionId1923106969";
+ *   Connection response =
+ *       connectionServiceClient.createConnection(parent, connection, connectionId);
+ * }
+ * }</pre>
+ *
  * <p>Note: close() needs to be called on the ConnectionServiceClient object to clean up resources
  * such as threads. In the example above, try-with-resources is used, which automatically calls
  * close().
@@ -165,6 +175,18 @@ public ConnectionServiceStub getStub() {
   /**
    * Creates a new connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   Connection connection = Connection.newBuilder().build();
+   *   String connectionId = "connectionId1923106969";
+   *   Connection response =
+   *       connectionServiceClient.createConnection(parent, connection, connectionId);
+   * }
+   * }</pre>
+   *
    * @param parent Required. Parent resource name. Must be in the format
    *     `projects/{project_id}/locations/{location_id}`
    * @param connection Required. Connection to create.
@@ -186,6 +208,18 @@ public final Connection createConnection(
   /**
    * Creates a new connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+   *   Connection connection = Connection.newBuilder().build();
+   *   String connectionId = "connectionId1923106969";
+   *   Connection response =
+   *       connectionServiceClient.createConnection(parent, connection, connectionId);
+   * }
+   * }</pre>
+   *
    * @param parent Required. Parent resource name. Must be in the format
    *     `projects/{project_id}/locations/{location_id}`
    * @param connection Required. Connection to create.
@@ -207,6 +241,20 @@ public final Connection createConnection(
   /**
    * Creates a new connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   CreateConnectionRequest request =
+   *       CreateConnectionRequest.newBuilder()
+   *           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+   *           .setConnectionId("connectionId1923106969")
+   *           .setConnection(Connection.newBuilder().build())
+   *           .build();
+   *   Connection response = connectionServiceClient.createConnection(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -219,6 +267,21 @@ public final Connection createConnection(CreateConnectionRequest request) {
    * Creates a new connection.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   CreateConnectionRequest request =
+   *       CreateConnectionRequest.newBuilder()
+   *           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+   *           .setConnectionId("connectionId1923106969")
+   *           .setConnection(Connection.newBuilder().build())
+   *           .build();
+   *   ApiFuture<Connection> future =
+   *       connectionServiceClient.createConnectionCallable().futureCall(request);
+   *   // Do something.
+   *   Connection response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<CreateConnectionRequest, Connection> createConnectionCallable() {
     return stub.createConnectionCallable();
@@ -228,6 +291,15 @@ public final UnaryCallable<CreateConnectionRequest, Connection> createConnection
   /**
    * Returns specified connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionName name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   Connection response = connectionServiceClient.getConnection(name);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the requested connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -242,6 +314,15 @@ public final Connection getConnection(ConnectionName name) {
   /**
    * Returns specified connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   Connection response = connectionServiceClient.getConnection(name);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the requested connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -255,6 +336,18 @@ public final Connection getConnection(String name) {
   /**
    * Returns specified connection.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   GetConnectionRequest request =
+   *       GetConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .build();
+   *   Connection response = connectionServiceClient.getConnection(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -267,6 +360,19 @@ public final Connection getConnection(GetConnectionRequest request) {
    * Returns specified connection.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   GetConnectionRequest request =
+   *       GetConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .build();
+   *   ApiFuture<Connection> future =
+   *       connectionServiceClient.getConnectionCallable().futureCall(request);
+   *   // Do something.
+   *   Connection response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<GetConnectionRequest, Connection> getConnectionCallable() {
     return stub.getConnectionCallable();
@@ -276,6 +382,17 @@ public final UnaryCallable<GetConnectionRequest, Connection> getConnectionCallab
   /**
    * Returns a list of connections in the given project.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+   *   for (Connection element : connectionServiceClient.listConnections(parent).iterateAll()) {
+   *     // doThingsWith(element);
+   *   }
+   * }
+   * }</pre>
+   *
    * @param parent Required. Parent resource name. Must be in the form:
    *     `projects/{project_id}/locations/{location_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -292,6 +409,17 @@ public final ListConnectionsPagedResponse listConnections(LocationName parent) {
   /**
    * Returns a list of connections in the given project.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
+   *   for (Connection element : connectionServiceClient.listConnections(parent).iterateAll()) {
+   *     // doThingsWith(element);
+   *   }
+   * }
+   * }</pre>
+   *
    * @param parent Required. Parent resource name. Must be in the form:
    *     `projects/{project_id}/locations/{location_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -305,6 +433,22 @@ public final ListConnectionsPagedResponse listConnections(String parent) {
   /**
    * Returns a list of connections in the given project.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ListConnectionsRequest request =
+   *       ListConnectionsRequest.newBuilder()
+   *           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+   *           .setPageSize(883849137)
+   *           .setPageToken("pageToken873572522")
+   *           .build();
+   *   for (Connection element : connectionServiceClient.listConnections(request).iterateAll()) {
+   *     // doThingsWith(element);
+   *   }
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -317,6 +461,23 @@ public final ListConnectionsPagedResponse listConnections(ListConnectionsRequest
    * Returns a list of connections in the given project.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ListConnectionsRequest request =
+   *       ListConnectionsRequest.newBuilder()
+   *           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
+   *           .setPageSize(883849137)
+   *           .setPageToken("pageToken873572522")
+   *           .build();
+   *   ApiFuture<Connection> future =
+   *       connectionServiceClient.listConnectionsPagedCallable().futureCall(request);
+   *   // Do something.
+   *   for (Connection element : future.get().iterateAll()) {
+   *     // doThingsWith(element);
+   *   }
+   * }
+   * }</pre>
    */
   public final UnaryCallable<ListConnectionsRequest, ListConnectionsPagedResponse>
       listConnectionsPagedCallable() {
@@ -328,6 +489,24 @@ public final ListConnectionsPagedResponse listConnections(ListConnectionsRequest
    * Returns a list of connections in the given project.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   while (true) {
+   *     ListConnectionsResponse response =
+   *         connectionServiceClient.listConnectionsCallable().call(request);
+   *     for (Connection element : response.getResponsesList()) {
+   *       // doThingsWith(element);
+   *     }
+   *     String nextPageToken = response.getNextPageToken();
+   *     if (!Strings.isNullOrEmpty(nextPageToken)) {
+   *       request = request.toBuilder().setPageToken(nextPageToken).build();
+   *     } else {
+   *       break;
+   *     }
+   *   }
+   * }
+   * }</pre>
    */
   public final UnaryCallable<ListConnectionsRequest, ListConnectionsResponse>
       listConnectionsCallable() {
@@ -339,6 +518,17 @@ public final ListConnectionsPagedResponse listConnections(ListConnectionsRequest
    * Updates the specified connection. For security reasons, also resets credential if connection
    * properties are in the update field mask.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionName name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   Connection connection = Connection.newBuilder().build();
+   *   FieldMask updateMask = FieldMask.newBuilder().build();
+   *   Connection response = connectionServiceClient.updateConnection(name, connection, updateMask);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the connection to update, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @param connection Required. Connection containing the updated fields.
@@ -361,6 +551,17 @@ public final Connection updateConnection(
    * Updates the specified connection. For security reasons, also resets credential if connection
    * properties are in the update field mask.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   Connection connection = Connection.newBuilder().build();
+   *   FieldMask updateMask = FieldMask.newBuilder().build();
+   *   Connection response = connectionServiceClient.updateConnection(name, connection, updateMask);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the connection to update, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @param connection Required. Connection containing the updated fields.
@@ -383,6 +584,20 @@ public final Connection updateConnection(
    * Updates the specified connection. For security reasons, also resets credential if connection
    * properties are in the update field mask.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   UpdateConnectionRequest request =
+   *       UpdateConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setConnection(Connection.newBuilder().build())
+   *           .setUpdateMask(FieldMask.newBuilder().build())
+   *           .build();
+   *   Connection response = connectionServiceClient.updateConnection(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -396,6 +611,21 @@ public final Connection updateConnection(UpdateConnectionRequest request) {
    * properties are in the update field mask.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   UpdateConnectionRequest request =
+   *       UpdateConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setConnection(Connection.newBuilder().build())
+   *           .setUpdateMask(FieldMask.newBuilder().build())
+   *           .build();
+   *   ApiFuture<Connection> future =
+   *       connectionServiceClient.updateConnectionCallable().futureCall(request);
+   *   // Do something.
+   *   Connection response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<UpdateConnectionRequest, Connection> updateConnectionCallable() {
     return stub.updateConnectionCallable();
@@ -405,6 +635,15 @@ public final UnaryCallable<UpdateConnectionRequest, Connection> updateConnection
   /**
    * Deletes connection and associated credential.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ConnectionName name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   connectionServiceClient.deleteConnection(name);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the deleted connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -419,6 +658,15 @@ public final void deleteConnection(ConnectionName name) {
   /**
    * Deletes connection and associated credential.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String name = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   connectionServiceClient.deleteConnection(name);
+   * }
+   * }</pre>
+   *
    * @param name Required. Name of the deleted connection, for example:
    *     `projects/{project_id}/locations/{location_id}/connections/{connection_id}`
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
@@ -432,6 +680,18 @@ public final void deleteConnection(String name) {
   /**
    * Deletes connection and associated credential.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   DeleteConnectionRequest request =
+   *       DeleteConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .build();
+   *   connectionServiceClient.deleteConnection(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -444,6 +704,19 @@ public final void deleteConnection(DeleteConnectionRequest request) {
    * Deletes connection and associated credential.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   DeleteConnectionRequest request =
+   *       DeleteConnectionRequest.newBuilder()
+   *           .setName(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .build();
+   *   ApiFuture<Empty> future =
+   *       connectionServiceClient.deleteConnectionCallable().futureCall(request);
+   *   // Do something.
+   *   future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<DeleteConnectionRequest, Empty> deleteConnectionCallable() {
     return stub.deleteConnectionCallable();
@@ -454,6 +727,16 @@ public final UnaryCallable<DeleteConnectionRequest, Empty> deleteConnectionCalla
    * Gets the access control policy for a resource. Returns an empty policy if the resource exists
    * and does not have a policy set.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ResourceName resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   GetPolicyOptions options = GetPolicyOptions.newBuilder().build();
+   *   Policy response = connectionServiceClient.getIamPolicy(resource, options);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy is being requested. See the
    *     operation documentation for the appropriate value for this field.
    * @param options OPTIONAL: A `GetPolicyOptions` object for specifying options to `GetIamPolicy`.
@@ -474,6 +757,16 @@ public final Policy getIamPolicy(ResourceName resource, GetPolicyOptions options
    * Gets the access control policy for a resource. Returns an empty policy if the resource exists
    * and does not have a policy set.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   GetPolicyOptions options = GetPolicyOptions.newBuilder().build();
+   *   Policy response = connectionServiceClient.getIamPolicy(resource, options);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy is being requested. See the
    *     operation documentation for the appropriate value for this field.
    * @param options OPTIONAL: A `GetPolicyOptions` object for specifying options to `GetIamPolicy`.
@@ -491,6 +784,19 @@ public final Policy getIamPolicy(String resource, GetPolicyOptions options) {
    * Gets the access control policy for a resource. Returns an empty policy if the resource exists
    * and does not have a policy set.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   GetIamPolicyRequest request =
+   *       GetIamPolicyRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setOptions(GetPolicyOptions.newBuilder().build())
+   *           .build();
+   *   Policy response = connectionServiceClient.getIamPolicy(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -504,6 +810,19 @@ public final Policy getIamPolicy(GetIamPolicyRequest request) {
    * and does not have a policy set.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   GetIamPolicyRequest request =
+   *       GetIamPolicyRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setOptions(GetPolicyOptions.newBuilder().build())
+   *           .build();
+   *   ApiFuture<Policy> future = connectionServiceClient.getIamPolicyCallable().futureCall(request);
+   *   // Do something.
+   *   Policy response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
     return stub.getIamPolicyCallable();
@@ -515,6 +834,16 @@ public final UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
    *
    * <p>Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ResourceName resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   Policy policy = Policy.newBuilder().build();
+   *   Policy response = connectionServiceClient.setIamPolicy(resource, policy);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy is being specified. See the
    *     operation documentation for the appropriate value for this field.
    * @param policy REQUIRED: The complete policy to be applied to the `resource`. The size of the
@@ -537,6 +866,16 @@ public final Policy setIamPolicy(ResourceName resource, Policy policy) {
    *
    * <p>Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   Policy policy = Policy.newBuilder().build();
+   *   Policy response = connectionServiceClient.setIamPolicy(resource, policy);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy is being specified. See the
    *     operation documentation for the appropriate value for this field.
    * @param policy REQUIRED: The complete policy to be applied to the `resource`. The size of the
@@ -556,6 +895,19 @@ public final Policy setIamPolicy(String resource, Policy policy) {
    *
    * <p>Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   SetIamPolicyRequest request =
+   *       SetIamPolicyRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setPolicy(Policy.newBuilder().build())
+   *           .build();
+   *   Policy response = connectionServiceClient.setIamPolicy(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -570,6 +922,19 @@ public final Policy setIamPolicy(SetIamPolicyRequest request) {
    * <p>Can return `NOT_FOUND`, `INVALID_ARGUMENT`, and `PERMISSION_DENIED` errors.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   SetIamPolicyRequest request =
+   *       SetIamPolicyRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .setPolicy(Policy.newBuilder().build())
+   *           .build();
+   *   ApiFuture<Policy> future = connectionServiceClient.setIamPolicyCallable().futureCall(request);
+   *   // Do something.
+   *   Policy response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {
     return stub.setIamPolicyCallable();
@@ -584,6 +949,17 @@ public final UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {
    * command-line tools, not for authorization checking. This operation may "fail open" without
    * warning.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   ResourceName resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]");
+   *   List<String> permissions = new ArrayList<>();
+   *   TestIamPermissionsResponse response =
+   *       connectionServiceClient.testIamPermissions(resource, permissions);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy detail is being requested. See the
    *     operation documentation for the appropriate value for this field.
    * @param permissions The set of permissions to check for the `resource`. Permissions with
@@ -610,6 +986,17 @@ public final TestIamPermissionsResponse testIamPermissions(
    * command-line tools, not for authorization checking. This operation may "fail open" without
    * warning.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   String resource = ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString();
+   *   List<String> permissions = new ArrayList<>();
+   *   TestIamPermissionsResponse response =
+   *       connectionServiceClient.testIamPermissions(resource, permissions);
+   * }
+   * }</pre>
+   *
    * @param resource REQUIRED: The resource for which the policy detail is being requested. See the
    *     operation documentation for the appropriate value for this field.
    * @param permissions The set of permissions to check for the `resource`. Permissions with
@@ -636,6 +1023,19 @@ public final TestIamPermissionsResponse testIamPermissions(
    * command-line tools, not for authorization checking. This operation may "fail open" without
    * warning.
    *
+   * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   TestIamPermissionsRequest request =
+   *       TestIamPermissionsRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .addAllPermissions(new ArrayList<String>())
+   *           .build();
+   *   TestIamPermissionsResponse response = connectionServiceClient.testIamPermissions(request);
+   * }
+   * }</pre>
+   *
    * @param request The request object containing all of the parameters for the API call.
    * @throws com.google.api.gax.rpc.ApiException if the remote call fails
    */
@@ -653,6 +1053,20 @@ public final TestIamPermissionsResponse testIamPermissions(TestIamPermissionsReq
    * warning.
    *
    * <p>Sample code:
+   *
+   * <pre>{@code
+   * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+   *   TestIamPermissionsRequest request =
+   *       TestIamPermissionsRequest.newBuilder()
+   *           .setResource(ConnectionName.of("[PROJECT]", "[LOCATION]", "[CONNECTION]").toString())
+   *           .addAllPermissions(new ArrayList<String>())
+   *           .build();
+   *   ApiFuture<TestIamPermissionsResponse> future =
+   *       connectionServiceClient.testIamPermissionsCallable().futureCall(request);
+   *   // Do something.
+   *   TestIamPermissionsResponse response = future.get();
+   * }
+   * }</pre>
    */
   public final UnaryCallable<TestIamPermissionsRequest, TestIamPermissionsResponse>
       testIamPermissionsCallable() {
diff --git a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/gapic_metadata.json b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/gapic_metadata.json
new file mode 100644
index 00000000..288163ab
--- /dev/null
+++ b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/gapic_metadata.json
@@ -0,0 +1,42 @@
+{
+  "schema": "1.0",
+  "comment": "This file maps proto services/RPCs to the corresponding library clients/methods",
+  "language": "java",
+  "protoPackage": "google.cloud.bigquery.connection.v1",
+  "libraryPackage": "com.google.cloud.bigqueryconnection.v1",
+  "services": {
+    "ConnectionService": {
+      "clients": {
+        "grpc": {
+          "libraryClient": "ConnectionServiceClient",
+          "rpcs": {
+            "CreateConnection": {
+              "methods": ["createConnection", "createConnection", "createConnection", "createConnectionCallable"]
+            },
+            "DeleteConnection": {
+              "methods": ["deleteConnection", "deleteConnection", "deleteConnection", "deleteConnectionCallable"]
+            },
+            "GetConnection": {
+              "methods": ["getConnection", "getConnection", "getConnection", "getConnectionCallable"]
+            },
+            "GetIamPolicy": {
+              "methods": ["getIamPolicy", "getIamPolicy", "getIamPolicy", "getIamPolicyCallable"]
+            },
+            "ListConnections": {
+              "methods": ["listConnections", "listConnections", "listConnections", "listConnectionsPagedCallable", "listConnectionsCallable"]
+            },
+            "SetIamPolicy": {
+              "methods": ["setIamPolicy", "setIamPolicy", "setIamPolicy", "setIamPolicyCallable"]
+            },
+            "TestIamPermissions": {
+              "methods": ["testIamPermissions", "testIamPermissions", "testIamPermissions", "testIamPermissionsCallable"]
+            },
+            "UpdateConnection": {
+              "methods": ["updateConnection", "updateConnection", "updateConnection", "updateConnectionCallable"]
+            }
+          }
+        }
+      }
+    }
+  }
+}
\ No newline at end of file
diff --git a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/package-info.java b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/package-info.java
index 88eb7a92..2909d29f 100644
--- a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/package-info.java
+++ b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/package-info.java
@@ -22,6 +22,16 @@
  * <p>Service Description: Manages external data source connections and credentials.
  *
  * <p>Sample for ConnectionServiceClient:
+ *
+ * <pre>{@code
+ * try (ConnectionServiceClient connectionServiceClient = ConnectionServiceClient.create()) {
+ *   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
+ *   Connection connection = Connection.newBuilder().build();
+ *   String connectionId = "connectionId1923106969";
+ *   Connection response =
+ *       connectionServiceClient.createConnection(parent, connection, connectionId);
+ * }
+ * }</pre>
  */
 @Generated("by gapic-generator-java")
 package com.google.cloud.bigqueryconnection.v1;
diff --git a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/stub/GrpcConnectionServiceStub.java b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/stub/GrpcConnectionServiceStub.java
index 5f57ad1f..5aecd0b6 100644
--- a/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/stub/GrpcConnectionServiceStub.java
+++ b/google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/stub/GrpcConnectionServiceStub.java
@@ -341,39 +341,48 @@ public GrpcOperationsStub getOperationsStub() {
     return operationsStub;
   }
 
+  @Override
   public UnaryCallable<CreateConnectionRequest, Connection> createConnectionCallable() {
     return createConnectionCallable;
   }
 
+  @Override
   public UnaryCallable<GetConnectionRequest, Connection> getConnectionCallable() {
     return getConnectionCallable;
   }
 
+  @Override
   public UnaryCallable<ListConnectionsRequest, ListConnectionsResponse> listConnectionsCallable() {
     return listConnectionsCallable;
   }
 
+  @Override
   public UnaryCallable<ListConnectionsRequest, ListConnectionsPagedResponse>
       listConnectionsPagedCallable() {
     return listConnectionsPagedCallable;
   }
 
+  @Override
   public UnaryCallable<UpdateConnectionRequest, Connection> updateConnectionCallable() {
     return updateConnectionCallable;
   }
 
+  @Override
   public UnaryCallable<DeleteConnectionRequest, Empty> deleteConnectionCallable() {
     return deleteConnectionCallable;
   }
 
+  @Override
   public UnaryCallable<GetIamPolicyRequest, Policy> getIamPolicyCallable() {
     return getIamPolicyCallable;
   }
 
+  @Override
   public UnaryCallable<SetIamPolicyRequest, Policy> setIamPolicyCallable() {
     return setIamPolicyCallable;
   }
 
+  @Override
   public UnaryCallable<TestIamPermissionsRequest, TestIamPermissionsResponse>
       testIamPermissionsCallable() {
     return testIamPermissionsCallable;
diff --git a/google-cloud-bigqueryconnection/src/test/java/com/google/cloud/bigquery/connection/v1beta1/MockConnectionServiceImpl.java b/google-cloud-bigqueryconnection/src/test/java/com/google/cloud/bigquery/connection/v1beta1/MockConnectionServiceImpl.java
index e16ea536..977aa871 100644
--- a/google-cloud-bigqueryconnection/src/test/java/com/google/cloud/bigquery/connection/v1beta1/MockConnectionServiceImpl.java
+++ b/google-cloud-bigqueryconnection/src/test/java/com/google/cloud/bigquery/connection/v1beta1/MockConnectionServiceImpl.java
@@ -76,7 +76,13 @@ public void createConnection(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method CreateConnection, expected %s or %s",
+                  response.getClass().getName(),
+                  ConnectionProto.Connection.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -92,7 +98,13 @@ public void getConnection(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method GetConnection, expected %s or %s",
+                  response.getClass().getName(),
+                  ConnectionProto.Connection.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -108,7 +120,13 @@ public void listConnections(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method ListConnections, expected %s or %s",
+                  response.getClass().getName(),
+                  ConnectionProto.ListConnectionsResponse.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -124,7 +142,13 @@ public void updateConnection(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method UpdateConnection, expected %s or %s",
+                  response.getClass().getName(),
+                  ConnectionProto.Connection.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -140,7 +164,13 @@ public void updateConnectionCredential(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method UpdateConnectionCredential, expected %s or %s",
+                  response.getClass().getName(),
+                  Empty.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -155,7 +185,13 @@ public void deleteConnection(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method DeleteConnection, expected %s or %s",
+                  response.getClass().getName(),
+                  Empty.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -169,7 +205,13 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> res
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
+                  response.getClass().getName(),
+                  Policy.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -183,7 +225,13 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> res
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
+                  response.getClass().getName(),
+                  Policy.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -199,7 +247,13 @@ public void testIamPermissions(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
+                  response.getClass().getName(),
+                  TestIamPermissionsResponse.class.getName(),
+                  Exception.class.getName())));
     }
   }
 }
diff --git a/google-cloud-bigqueryconnection/src/test/java/com/google/cloud/bigqueryconnection/v1/MockConnectionServiceImpl.java b/google-cloud-bigqueryconnection/src/test/java/com/google/cloud/bigqueryconnection/v1/MockConnectionServiceImpl.java
index fbafb47b..1ec36670 100644
--- a/google-cloud-bigqueryconnection/src/test/java/com/google/cloud/bigqueryconnection/v1/MockConnectionServiceImpl.java
+++ b/google-cloud-bigqueryconnection/src/test/java/com/google/cloud/bigqueryconnection/v1/MockConnectionServiceImpl.java
@@ -82,7 +82,13 @@ public void createConnection(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method CreateConnection, expected %s or %s",
+                  response.getClass().getName(),
+                  Connection.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -97,7 +103,13 @@ public void getConnection(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method GetConnection, expected %s or %s",
+                  response.getClass().getName(),
+                  Connection.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -112,7 +124,13 @@ public void listConnections(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method ListConnections, expected %s or %s",
+                  response.getClass().getName(),
+                  ListConnectionsResponse.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -127,7 +145,13 @@ public void updateConnection(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method UpdateConnection, expected %s or %s",
+                  response.getClass().getName(),
+                  Connection.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -142,7 +166,13 @@ public void deleteConnection(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method DeleteConnection, expected %s or %s",
+                  response.getClass().getName(),
+                  Empty.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -156,7 +186,13 @@ public void getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> res
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method GetIamPolicy, expected %s or %s",
+                  response.getClass().getName(),
+                  Policy.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -170,7 +206,13 @@ public void setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> res
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method SetIamPolicy, expected %s or %s",
+                  response.getClass().getName(),
+                  Policy.class.getName(),
+                  Exception.class.getName())));
     }
   }
 
@@ -186,7 +228,13 @@ public void testIamPermissions(
     } else if (response instanceof Exception) {
       responseObserver.onError(((Exception) response));
     } else {
-      responseObserver.onError(new IllegalArgumentException("Unrecognized response type"));
+      responseObserver.onError(
+          new IllegalArgumentException(
+              String.format(
+                  "Unrecognized response type %s for method TestIamPermissions, expected %s or %s",
+                  response.getClass().getName(),
+                  TestIamPermissionsResponse.class.getName(),
+                  Exception.class.getName())));
     }
   }
 }
diff --git a/grpc-google-cloud-bigqueryconnection-v1/pom.xml b/grpc-google-cloud-bigqueryconnection-v1/pom.xml
index 5c6735d0..89483222 100644
--- a/grpc-google-cloud-bigqueryconnection-v1/pom.xml
+++ b/grpc-google-cloud-bigqueryconnection-v1/pom.xml
@@ -4,13 +4,13 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.google.api.grpc</groupId>
   <artifactId>grpc-google-cloud-bigqueryconnection-v1</artifactId>
-  <version>1.0.8</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1:current} -->
+  <version>1.0.9</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1:current} -->
   <name>grpc-google-cloud-bigqueryconnection-v1</name>
   <description>GRPC library for grpc-google-cloud-bigqueryconnection-v1</description>
   <parent>
     <groupId>com.google.cloud</groupId>
     <artifactId>google-cloud-bigqueryconnection-parent</artifactId>
-    <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+    <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
   </parent>
   <dependencies>
     <dependency>
diff --git a/grpc-google-cloud-bigqueryconnection-v1beta1/pom.xml b/grpc-google-cloud-bigqueryconnection-v1beta1/pom.xml
index f5fd862d..9fc7311e 100644
--- a/grpc-google-cloud-bigqueryconnection-v1beta1/pom.xml
+++ b/grpc-google-cloud-bigqueryconnection-v1beta1/pom.xml
@@ -4,13 +4,13 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.google.api.grpc</groupId>
   <artifactId>grpc-google-cloud-bigqueryconnection-v1beta1</artifactId>
-  <version>0.5.8</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1beta1:current} -->
+  <version>0.5.9</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1beta1:current} -->
   <name>grpc-google-cloud-bigqueryconnection-v1beta1</name>
   <description>GRPC library for grpc-google-cloud-bigqueryconnection-v1beta1</description>
   <parent>
     <groupId>com.google.cloud</groupId>
     <artifactId>google-cloud-bigqueryconnection-parent</artifactId>
-    <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+    <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
   </parent>
   <dependencies>
     <dependency>
diff --git a/pom.xml b/pom.xml
index d508ece3..4714bf1f 100644
--- a/pom.xml
+++ b/pom.xml
@@ -4,7 +4,7 @@
   <groupId>com.google.cloud</groupId>
   <artifactId>google-cloud-bigqueryconnection-parent</artifactId>
   <packaging>pom</packaging>
-  <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+  <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
   <name>Google Cloud BigQuery Connections Parent</name>
   <url>https://github.com/googleapis/java-bigqueryconnection</url>
   <description>
@@ -14,7 +14,7 @@
   <parent>
     <groupId>com.google.cloud</groupId>
     <artifactId>google-cloud-shared-config</artifactId>
-    <version>0.9.4</version>
+    <version>0.10.0</version>
   </parent>
 
   <developers>
@@ -44,11 +44,11 @@
   <distributionManagement>
     <snapshotRepository>
       <id>sonatype-nexus-snapshots</id>
-      <url>https://oss.sonatype.org/content/repositories/snapshots</url>
+      <url>https://google.oss.sonatype.org/content/repositories/snapshots</url>
     </snapshotRepository>
     <repository>
       <id>sonatype-nexus-staging</id>
-      <url>https://oss.sonatype.org/service/local/staging/deploy/maven2/</url>
+      <url>https://google.oss.sonatype.org/service/local/staging/deploy/maven2/</url>
     </repository>
   </distributionManagement>
   <licenses>
@@ -63,7 +63,7 @@
     <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
     <github.global.server>github</github.global.server>
     <site.installationModule>google-cloud-bigqueryconnection-parent</site.installationModule>
-    <google.cloud.shared-dependencies.version>0.18.0</google.cloud.shared-dependencies.version>
+    <google.cloud.shared-dependencies.version>0.19.0</google.cloud.shared-dependencies.version>
   </properties>
 
   <dependencyManagement>
@@ -71,27 +71,27 @@
       <dependency>
         <groupId>com.google.cloud</groupId>
         <artifactId>google-cloud-bigqueryconnection</artifactId>
-        <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+        <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
       </dependency>
       <dependency>
         <groupId>com.google.api.grpc</groupId>
         <artifactId>proto-google-cloud-bigqueryconnection-v1</artifactId>
-        <version>1.0.8</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1:current} -->
+        <version>1.0.9</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1:current} -->
       </dependency>
       <dependency>
         <groupId>com.google.api.grpc</groupId>
         <artifactId>grpc-google-cloud-bigqueryconnection-v1</artifactId>
-        <version>1.0.8</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1:current} -->
+        <version>1.0.9</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1:current} -->
       </dependency>
       <dependency>
         <groupId>com.google.api.grpc</groupId>
         <artifactId>proto-google-cloud-bigqueryconnection-v1beta1</artifactId>
-        <version>0.5.8</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1beta1:current} -->
+        <version>0.5.9</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1beta1:current} -->
       </dependency>
       <dependency>
         <groupId>com.google.api.grpc</groupId>
         <artifactId>grpc-google-cloud-bigqueryconnection-v1beta1</artifactId>
-        <version>0.5.8</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1beta1:current} -->
+        <version>0.5.9</version><!-- {x-version-update:grpc-google-cloud-bigqueryconnection-v1beta1:current} -->
       </dependency>
 
       <dependency>
@@ -106,7 +106,7 @@
       <dependency>
         <groupId>junit</groupId>
         <artifactId>junit</artifactId>
-        <version>4.13.1</version>
+        <version>4.13.2</version>
         <scope>test</scope>
       </dependency>
     </dependencies>
@@ -115,6 +115,18 @@
   <build>
     <pluginManagement>
       <plugins>
+        <plugin>
+          <groupId>org.sonatype.plugins</groupId>
+          <artifactId>nexus-staging-maven-plugin</artifactId>
+          <version>1.6.8</version>
+          <extensions>true</extensions>
+          <configuration>
+            <serverId>ossrh</serverId>
+            <nexusUrl>https://google.oss.sonatype.org/</nexusUrl>
+            <autoReleaseAfterClose>false</autoReleaseAfterClose>
+            <stagingProgressTimeoutMinutes>15</stagingProgressTimeoutMinutes>
+          </configuration>
+        </plugin>
         <plugin>
           <groupId>org.apache.maven.plugins</groupId>
           <artifactId>maven-dependency-plugin</artifactId>
diff --git a/proto-google-cloud-bigqueryconnection-v1/pom.xml b/proto-google-cloud-bigqueryconnection-v1/pom.xml
index 47af822c..886adf5a 100644
--- a/proto-google-cloud-bigqueryconnection-v1/pom.xml
+++ b/proto-google-cloud-bigqueryconnection-v1/pom.xml
@@ -4,13 +4,13 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.google.api.grpc</groupId>
   <artifactId>proto-google-cloud-bigqueryconnection-v1</artifactId>
-  <version>1.0.8</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1:current} -->
+  <version>1.0.9</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1:current} -->
   <name>proto-google-cloud-bigqueryconnection-v1</name>
   <description>PROTO library for proto-google-cloud-bigqueryconnection-v1</description>
   <parent>
     <groupId>com.google.cloud</groupId>
     <artifactId>google-cloud-bigqueryconnection-parent</artifactId>
-    <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+    <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
   </parent>
   <dependencies>
     <dependency>
diff --git a/proto-google-cloud-bigqueryconnection-v1beta1/pom.xml b/proto-google-cloud-bigqueryconnection-v1beta1/pom.xml
index 1e763a83..8f702757 100644
--- a/proto-google-cloud-bigqueryconnection-v1beta1/pom.xml
+++ b/proto-google-cloud-bigqueryconnection-v1beta1/pom.xml
@@ -4,13 +4,13 @@
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.google.api.grpc</groupId>
   <artifactId>proto-google-cloud-bigqueryconnection-v1beta1</artifactId>
-  <version>0.5.8</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1beta1:current} -->
+  <version>0.5.9</version><!-- {x-version-update:proto-google-cloud-bigqueryconnection-v1beta1:current} -->
   <name>proto-google-cloud-bigqueryconnection-v1beta1</name>
   <description>PROTO library for proto-google-cloud-bigqueryconnection-v1beta1</description>
   <parent>
     <groupId>com.google.cloud</groupId>
     <artifactId>google-cloud-bigqueryconnection-parent</artifactId>
-    <version>1.0.8</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
+    <version>1.0.9</version><!-- {x-version-update:google-cloud-bigqueryconnection:current} -->
   </parent>
   <dependencies>
     <dependency>
diff --git a/samples/install-without-bom/pom.xml b/samples/install-without-bom/pom.xml
index 46a0d852..3d5ac548 100644
--- a/samples/install-without-bom/pom.xml
+++ b/samples/install-without-bom/pom.xml
@@ -29,19 +29,19 @@
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-bigqueryconnection</artifactId>
-      <version>1.0.7</version>
+      <version>1.0.8</version>
     </dependency>
     <!-- [END bigqueryconnection_install_without_bom] -->
 
     <dependency>
       <groupId>com.google.protobuf</groupId>
       <artifactId>protobuf-java-util</artifactId>
-      <version>3.14.0</version>
+      <version>3.15.1</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>
       <artifactId>junit</artifactId>
-      <version>4.13.1</version>
+      <version>4.13.2</version>
       <scope>test</scope>
     </dependency>
     <dependency>
diff --git a/samples/snapshot/pom.xml b/samples/snapshot/pom.xml
index f2808f08..736cbb7c 100644
--- a/samples/snapshot/pom.xml
+++ b/samples/snapshot/pom.xml
@@ -28,19 +28,19 @@
     <dependency>
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-bigqueryconnection</artifactId>
-      <version>1.0.8</version>
+      <version>1.0.9</version>
     </dependency>
     <!-- {x-version-update-end} -->
 
     <dependency>
       <groupId>com.google.protobuf</groupId>
       <artifactId>protobuf-java-util</artifactId>
-      <version>3.14.0</version>
+      <version>3.15.1</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>
       <artifactId>junit</artifactId>
-      <version>4.13.1</version>
+      <version>4.13.2</version>
       <scope>test</scope>
     </dependency>
     <dependency>
diff --git a/samples/snippets/pom.xml b/samples/snippets/pom.xml
index dc6f79d7..51933a53 100644
--- a/samples/snippets/pom.xml
+++ b/samples/snippets/pom.xml
@@ -28,7 +28,7 @@
       <dependency>
         <groupId>com.google.cloud</groupId>
         <artifactId>libraries-bom</artifactId>
-        <version>16.2.1</version>
+        <version>16.4.0</version>
         <type>pom</type>
         <scope>import</scope>
       </dependency>
@@ -40,18 +40,18 @@
       <groupId>com.google.cloud</groupId>
       <artifactId>google-cloud-bigqueryconnection</artifactId>
       <!-- TODO: REMOVE VERSION SPECIFIED BELOW WHEN THE CLIENT GOES GA-->
-      <version>1.0.7</version>
+      <version>1.0.8</version>
     </dependency>
 
     <dependency>
       <groupId>com.google.protobuf</groupId>
       <artifactId>protobuf-java-util</artifactId>
-      <version>3.14.0</version>
+      <version>3.15.1</version>
     </dependency>
     <dependency>
       <groupId>junit</groupId>
       <artifactId>junit</artifactId>
-      <version>4.13.1</version>
+      <version>4.13.2</version>
       <scope>test</scope>
     </dependency>
     <dependency>
diff --git a/synth.metadata b/synth.metadata
index c36a6df1..d354ad60 100644
--- a/synth.metadata
+++ b/synth.metadata
@@ -4,30 +4,30 @@
       "git": {
         "name": ".",
         "remote": "https://github.com/googleapis/java-bigqueryconnection.git",
-        "sha": "bd3c91e3fbb458a355295042ca2b700970bac1d4"
+        "sha": "98ee3cf4a022efaf53ad0d29a96ae68509ac5232"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "91e206bcfeaf8948ea03fe3cb1b7616108496cd3",
-        "internalRef": "350949863"
+        "sha": "af8f71dae961ee036a0ac52a1965270149a6b2c9",
+        "internalRef": "358516065"
       }
     },
     {
       "git": {
         "name": "googleapis",
         "remote": "https://github.com/googleapis/googleapis.git",
-        "sha": "91e206bcfeaf8948ea03fe3cb1b7616108496cd3",
-        "internalRef": "350949863"
+        "sha": "af8f71dae961ee036a0ac52a1965270149a6b2c9",
+        "internalRef": "358516065"
       }
     },
     {
       "git": {
         "name": "synthtool",
         "remote": "https://github.com/googleapis/synthtool.git",
-        "sha": "6133907dbb3ddab204a17a15d5c53ec0aae9b033"
+        "sha": "6946fd71ae9215b0e7ae188f5057df765ee6d7d2"
       }
     }
   ],
@@ -75,7 +75,6 @@
     ".kokoro/continuous/java8.cfg",
     ".kokoro/continuous/readme.cfg",
     ".kokoro/dependencies.sh",
-    ".kokoro/linkage-monitor.sh",
     ".kokoro/nightly/common.cfg",
     ".kokoro/nightly/java11.cfg",
     ".kokoro/nightly/java7.cfg",
@@ -103,6 +102,8 @@
     ".kokoro/release/promote.sh",
     ".kokoro/release/publish_javadoc.cfg",
     ".kokoro/release/publish_javadoc.sh",
+    ".kokoro/release/publish_javadoc11.cfg",
+    ".kokoro/release/publish_javadoc11.sh",
     ".kokoro/release/snapshot.cfg",
     ".kokoro/release/snapshot.sh",
     ".kokoro/release/stage.cfg",
@@ -114,6 +115,7 @@
     "codecov.yaml",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/ConnectionServiceClient.java",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/ConnectionServiceSettings.java",
+    "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/gapic_metadata.json",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/package-info.java",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/stub/ConnectionServiceStub.java",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/stub/ConnectionServiceStubSettings.java",
@@ -121,6 +123,7 @@
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigquery/connection/v1beta1/stub/GrpcConnectionServiceStub.java",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/ConnectionServiceClient.java",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/ConnectionServiceSettings.java",
+    "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/gapic_metadata.json",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/package-info.java",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/stub/ConnectionServiceStub.java",
     "google-cloud-bigqueryconnection/src/main/java/com/google/cloud/bigqueryconnection/v1/stub/ConnectionServiceStubSettings.java",
diff --git a/versions.txt b/versions.txt
index f0d12c73..0b449b13 100644
--- a/versions.txt
+++ b/versions.txt
@@ -1,8 +1,8 @@
 # Format:
 # module:released-version:current-version
 
-google-cloud-bigqueryconnection:1.0.8:1.0.8
-proto-google-cloud-bigqueryconnection-v1:1.0.8:1.0.8
-grpc-google-cloud-bigqueryconnection-v1:1.0.8:1.0.8
-proto-google-cloud-bigqueryconnection-v1beta1:0.5.8:0.5.8
-grpc-google-cloud-bigqueryconnection-v1beta1:0.5.8:0.5.8
+google-cloud-bigqueryconnection:1.0.9:1.0.9
+proto-google-cloud-bigqueryconnection-v1:1.0.9:1.0.9
+grpc-google-cloud-bigqueryconnection-v1:1.0.9:1.0.9
+proto-google-cloud-bigqueryconnection-v1beta1:0.5.9:0.5.9
+grpc-google-cloud-bigqueryconnection-v1beta1:0.5.9:0.5.9