fix

Author: sushanb

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/stub/BigtableClientContext.java

@@ -175,8 +175,9 @@ public static BigtableClientContext create(
           break;
         case DEFAULT:
         default:
-          System.out.println("Using default direct access checker");
-          directAccessChecker = new ClassicDirectAccessChecker(metrics.getDirectPathCompatibleTracer(), channelPrimer, backgroundExecutor);
+          directAccessChecker =
+              new ClassicDirectAccessChecker(
+                  metrics.getDirectPathCompatibleTracer(), channelPrimer, backgroundExecutor);
           break;
       }
 

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/BigtableDataClientFactoryTest.java

@@ -286,15 +286,15 @@ public void testCreateWithRefreshingChannel() throws Exception {
     Mockito.verify(credentialsProvider, Mockito.times(2)).getCredentials();
     Mockito.verify(executorProvider, Mockito.times(1)).getExecutor();
     Mockito.verify(watchdogProvider, Mockito.times(1)).getWatchdog();
-    assertThat(warmedChannels).hasSize(poolSize+1);
+    assertThat(warmedChannels).hasSize(poolSize + 1);
     assertThat(warmedChannels.values()).doesNotContain(false);
 
     // Wait for all the connections to close asynchronously
     factory.close();
     long sleepTimeMs = 1000;
     Thread.sleep(sleepTimeMs);
     // Verify that all the channels are closed
-    assertThat(terminateAttributes).hasSize(poolSize+1);
+    assertThat(terminateAttributes).hasSize(poolSize + 1);
   }
 
   @Test
@@ -303,19 +303,19 @@ public void testCreateWithRefreshingChannelWithDirectAccessByDefault() throws Ex
     // TODO: remove the suppression when setRefreshingChannel can be removed
     @SuppressWarnings("deprecation")
     BigtableDataSettings.Builder builder =
-            BigtableDataSettings.newBuilderForEmulator(server.getPort())
-                    .setProjectId(DEFAULT_PROJECT_ID)
-                    .setInstanceId(DEFAULT_INSTANCE_ID)
-                    .setAppProfileId(DEFAULT_APP_PROFILE_ID)
-                    .setRefreshingChannel(true);
+        BigtableDataSettings.newBuilderForEmulator(server.getPort())
+            .setProjectId(DEFAULT_PROJECT_ID)
+            .setInstanceId(DEFAULT_INSTANCE_ID)
+            .setAppProfileId(DEFAULT_APP_PROFILE_ID)
+            .setRefreshingChannel(true);
     builder
-            .stubSettings()
-            .setCredentialsProvider(credentialsProvider)
-            .setStreamWatchdogProvider(watchdogProvider)
-            .setBackgroundExecutorProvider(executorProvider)
-            .setDirectPathConfig(EnhancedBigtableStubSettings.DirectPathConfig.DEFAULT);
+        .stubSettings()
+        .setCredentialsProvider(credentialsProvider)
+        .setStreamWatchdogProvider(watchdogProvider)
+        .setBackgroundExecutorProvider(executorProvider)
+        .setDirectPathConfig(EnhancedBigtableStubSettings.DirectPathConfig.DEFAULT);
     InstantiatingGrpcChannelProvider channelProvider =
-            (InstantiatingGrpcChannelProvider) builder.stubSettings().getTransportChannelProvider();
+        (InstantiatingGrpcChannelProvider) builder.stubSettings().getTransportChannelProvider();
     InstantiatingGrpcChannelProvider.Builder channelProviderBuilder = channelProvider.toBuilder();
     channelProviderBuilder.setChannelPoolSettings(ChannelPoolSettings.staticallySized(poolSize));
     builder.stubSettings().setTransportChannelProvider(channelProviderBuilder.build());
@@ -331,7 +331,7 @@ public void testCreateWithRefreshingChannelWithDirectAccessByDefault() throws Ex
     Mockito.verify(credentialsProvider, Mockito.times(2)).getCredentials();
     Mockito.verify(executorProvider, Mockito.times(1)).getExecutor();
     Mockito.verify(watchdogProvider, Mockito.times(1)).getWatchdog();
-    assertThat(warmedChannels).hasSize(poolSize+1);
+    assertThat(warmedChannels).hasSize(poolSize + 1);
     assertThat(warmedChannels.values()).doesNotContain(false);
 
     // Wait for all the connections to close asynchronously
@@ -340,30 +340,29 @@ public void testCreateWithRefreshingChannelWithDirectAccessByDefault() throws Ex
     Thread.sleep(sleepTimeMs);
     // Verify that all the channels are closed
     // If we have DEFAULT, it will add one channel temporily
-    assertThat(terminateAttributes).hasSize(poolSize+1);
+    assertThat(terminateAttributes).hasSize(poolSize + 1);
   }
 
-
   @Test
   public void testCreateWithRefreshingChannelDisableDirectAccess() throws Exception {
     int poolSize = 3;
     // TODO: remove the suppression when setRefreshingChannel can be removed
     @SuppressWarnings("deprecation")
     BigtableDataSettings.Builder builder =
-            BigtableDataSettings.newBuilderForEmulator(server.getPort())
-                    .setProjectId(DEFAULT_PROJECT_ID)
-                    .setInstanceId(DEFAULT_INSTANCE_ID)
-                    .setAppProfileId(DEFAULT_APP_PROFILE_ID)
-                    .setRefreshingChannel(true);
+        BigtableDataSettings.newBuilderForEmulator(server.getPort())
+            .setProjectId(DEFAULT_PROJECT_ID)
+            .setInstanceId(DEFAULT_INSTANCE_ID)
+            .setAppProfileId(DEFAULT_APP_PROFILE_ID)
+            .setRefreshingChannel(true);
 
     builder
-            .stubSettings()
-            .setCredentialsProvider(credentialsProvider)
-            .setStreamWatchdogProvider(watchdogProvider)
-            .setBackgroundExecutorProvider(executorProvider)
-            .setDirectPathConfig(EnhancedBigtableStubSettings.DirectPathConfig.FORCED_OFF);
+        .stubSettings()
+        .setCredentialsProvider(credentialsProvider)
+        .setStreamWatchdogProvider(watchdogProvider)
+        .setBackgroundExecutorProvider(executorProvider)
+        .setDirectPathConfig(EnhancedBigtableStubSettings.DirectPathConfig.FORCED_OFF);
     InstantiatingGrpcChannelProvider channelProvider =
-            (InstantiatingGrpcChannelProvider) builder.stubSettings().getTransportChannelProvider();
+        (InstantiatingGrpcChannelProvider) builder.stubSettings().getTransportChannelProvider();
     InstantiatingGrpcChannelProvider.Builder channelProviderBuilder = channelProvider.toBuilder();
     channelProviderBuilder.setChannelPoolSettings(ChannelPoolSettings.staticallySized(poolSize));
     builder.stubSettings().setTransportChannelProvider(channelProviderBuilder.build());

google-cloud-bigtable/src/test/java/com/google/cloud/bigtable/data/v2/stub/EnhancedBigtableStubTest.java

@@ -549,7 +549,10 @@ public void testChannelPrimerConfigured() throws IOException {
     // TODO: remove the suppression once setRefreshingChannel can be removed
     @SuppressWarnings("deprecation")
     EnhancedBigtableStubSettings settings =
-        defaultSettings.toBuilder().setRefreshingChannel(true).setDirectPathConfig(EnhancedBigtableStubSettings.DirectPathConfig.DEFAULT).build();
+        defaultSettings.toBuilder()
+            .setRefreshingChannel(true)
+            .setDirectPathConfig(EnhancedBigtableStubSettings.DirectPathConfig.DEFAULT)
+            .build();
 
     try (EnhancedBigtableStub ignored = EnhancedBigtableStub.create(settings)) {
       // direct access checker ping