diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStub.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStub.java
index 01bc24152..277af8c52 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStub.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStub.java
@@ -602,22 +602,9 @@ private <ReqT, RowT> ServerStreamingCallable<ReadRowsRequest, RowT> createReadRo
             GrpcCallSettings.<ReadRowsRequest, ReadRowsResponse>newBuilder()
                 .setMethodDescriptor(BigtableGrpc.getReadRowsMethod())
                 .setParamsExtractor(
-                    new RequestParamsExtractor<ReadRowsRequest>() {
-                      @Override
-                      public Map<String, String> extract(ReadRowsRequest readRowsRequest) {
-                        String tableName = readRowsRequest.getTableName();
-                        String authorizedViewName = readRowsRequest.getAuthorizedViewName();
-                        if (tableName.isEmpty()) {
-                          tableName =
-                              NameUtil.extractTableNameFromAuthorizedViewName(authorizedViewName);
-                        }
-                        return ImmutableMap.of(
-                            "table_name",
-                            tableName,
-                            "app_profile_id",
-                            readRowsRequest.getAppProfileId());
-                      }
-                    })
+                    r ->
+                        composeRequestParams(
+                            r.getAppProfileId(), r.getTableName(), r.getAuthorizedViewName()))
                 .build(),
             readRowsSettings.getRetryableCodes());
 
@@ -712,25 +699,9 @@ private <RowT> UnaryCallable<Query, List<RowT>> createBulkReadRowsCallable(
                         newBuilder()
                     .setMethodDescriptor(BigtableGrpc.getSampleRowKeysMethod())
                     .setParamsExtractor(
-                        new RequestParamsExtractor<com.google.bigtable.v2.SampleRowKeysRequest>() {
-                          @Override
-                          public Map<String, String> extract(
-                              com.google.bigtable.v2.SampleRowKeysRequest sampleRowKeysRequest) {
-                            String tableName = sampleRowKeysRequest.getTableName();
-                            String authorizedViewName =
-                                sampleRowKeysRequest.getAuthorizedViewName();
-                            if (tableName.isEmpty()) {
-                              tableName =
-                                  NameUtil.extractTableNameFromAuthorizedViewName(
-                                      authorizedViewName);
-                            }
-                            return ImmutableMap.of(
-                                "table_name",
-                                tableName,
-                                "app_profile_id",
-                                sampleRowKeysRequest.getAppProfileId());
-                          }
-                        })
+                        r ->
+                            composeRequestParams(
+                                r.getAppProfileId(), r.getTableName(), r.getAuthorizedViewName()))
                     .build(),
                 settings.sampleRowKeysSettings().getRetryableCodes());
 
@@ -836,22 +807,9 @@ private UnaryCallable<BulkMutation, MutateRowsAttemptResult> createMutateRowsBas
             GrpcCallSettings.<MutateRowsRequest, MutateRowsResponse>newBuilder()
                 .setMethodDescriptor(BigtableGrpc.getMutateRowsMethod())
                 .setParamsExtractor(
-                    new RequestParamsExtractor<MutateRowsRequest>() {
-                      @Override
-                      public Map<String, String> extract(MutateRowsRequest mutateRowsRequest) {
-                        String tableName = mutateRowsRequest.getTableName();
-                        String authorizedViewName = mutateRowsRequest.getAuthorizedViewName();
-                        if (tableName.isEmpty()) {
-                          tableName =
-                              NameUtil.extractTableNameFromAuthorizedViewName(authorizedViewName);
-                        }
-                        return ImmutableMap.of(
-                            "table_name",
-                            tableName,
-                            "app_profile_id",
-                            mutateRowsRequest.getAppProfileId());
-                      }
-                    })
+                    r ->
+                        composeRequestParams(
+                            r.getAppProfileId(), r.getTableName(), r.getAuthorizedViewName()))
                 .build(),
             settings.bulkMutateRowsSettings().getRetryableCodes());
 
@@ -1088,18 +1046,7 @@ private UnaryCallable<ReadModifyWriteRow, Row> createReadModifyWriteRowCallable(
                     .setMethodDescriptor(
                         BigtableGrpc.getGenerateInitialChangeStreamPartitionsMethod())
                     .setParamsExtractor(
-                        new RequestParamsExtractor<GenerateInitialChangeStreamPartitionsRequest>() {
-                          @Override
-                          public Map<String, String> extract(
-                              GenerateInitialChangeStreamPartitionsRequest
-                                  generateInitialChangeStreamPartitionsRequest) {
-                            return ImmutableMap.of(
-                                "table_name",
-                                generateInitialChangeStreamPartitionsRequest.getTableName(),
-                                "app_profile_id",
-                                generateInitialChangeStreamPartitionsRequest.getAppProfileId());
-                          }
-                        })
+                        r -> composeRequestParams(r.getAppProfileId(), r.getTableName(), ""))
                     .build(),
                 settings.generateInitialChangeStreamPartitionsSettings().getRetryableCodes());
 
@@ -1168,15 +1115,7 @@ public Map<String, String> extract(
             GrpcCallSettings.<ReadChangeStreamRequest, ReadChangeStreamResponse>newBuilder()
                 .setMethodDescriptor(BigtableGrpc.getReadChangeStreamMethod())
                 .setParamsExtractor(
-                    new RequestParamsExtractor<ReadChangeStreamRequest>() {
-                      @Override
-                      public Map<String, String> extract(
-                          ReadChangeStreamRequest readChangeStreamRequest) {
-                        return ImmutableMap.of(
-                            "table_name", readChangeStreamRequest.getTableName(),
-                            "app_profile_id", readChangeStreamRequest.getAppProfileId());
-                      }
-                    })
+                    r -> composeRequestParams(r.getAppProfileId(), r.getTableName(), ""))
                 .build(),
             settings.readChangeStreamSettings().getRetryableCodes());
 
@@ -1326,7 +1265,7 @@ private <RequestT, ResponseT> UnaryCallable<RequestT, ResponseT> createUserFacin
 
   private Map<String, String> composeRequestParams(
       String appProfileId, String tableName, String authorizedViewName) {
-    if (tableName.isEmpty()) {
+    if (tableName.isEmpty() && !authorizedViewName.isEmpty()) {
       tableName = NameUtil.extractTableNameFromAuthorizedViewName(authorizedViewName);
     }
     return ImmutableMap.of("table_name", tableName, "app_profile_id", appProfileId);