fix

Author: sushanb

google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/internal/dp/ClassicDirectAccessChecker.java

@@ -64,21 +64,19 @@ public boolean check(Channel channel) {
     }
   }
 
-  /**
-   * Executes the underlying RPC and evaluates the eligibility.
-   */
+  /** Executes the underlying RPC and evaluates the eligibility. */
   private boolean evaluateEligibility(Channel channel) {
     MetadataExtractorInterceptor interceptor = createInterceptor();
     Channel interceptedChannel = ClientInterceptors.intercept(channel, interceptor);
     channelPrimer.primeChannel(interceptedChannel);
     MetadataExtractorInterceptor.SidebandData sidebandData = interceptor.getSidebandData();
 
     boolean isEligible =
-            Optional.ofNullable(sidebandData)
-                    .map(MetadataExtractorInterceptor.SidebandData::getPeerInfo)
-                    .map(PeerInfo::getTransportType)
-                    .map(type -> type == PeerInfo.TransportType.TRANSPORT_TYPE_DIRECT_ACCESS)
-                    .orElse(false);
+        Optional.ofNullable(sidebandData)
+            .map(MetadataExtractorInterceptor.SidebandData::getPeerInfo)
+            .map(PeerInfo::getTransportType)
+            .map(type -> type == PeerInfo.TransportType.TRANSPORT_TYPE_DIRECT_ACCESS)
+            .orElse(false);
 
     if (isEligible) {
       // getIp should be non-null as isEligible is true

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

@@ -252,25 +252,24 @@ public ClientOperationSettings getPerOpSettings() {
     return perOpSettings;
   }
 
-
   /** Returns a builder for the default ChannelProvider for this service. */
   public static InstantiatingGrpcChannelProvider.Builder defaultGrpcTransportProviderBuilder() {
     InstantiatingGrpcChannelProvider.Builder grpcTransportProviderBuilder =
-            BigtableStubSettings.defaultGrpcTransportProviderBuilder();
+        BigtableStubSettings.defaultGrpcTransportProviderBuilder();
     return grpcTransportProviderBuilder
-            .setChannelPoolSettings(
-                    ChannelPoolSettings.builder()
-                            .setInitialChannelCount(10)
-                            .setMinRpcsPerChannel(1)
-                            // Keep it conservative as we scale the channel size every 1min
-                            // and delta is 2 channels.
-                            .setMaxRpcsPerChannel(25)
-                            .setPreemptiveRefreshEnabled(true)
-                            .build())
-            .setMaxInboundMessageSize(MAX_MESSAGE_SIZE)
-            .setKeepAliveTime(Duration.ofSeconds(30)) // sends ping in this interval
-            .setKeepAliveTimeout(
-                    Duration.ofSeconds(10)); // wait this long before considering the connection dead
+        .setChannelPoolSettings(
+            ChannelPoolSettings.builder()
+                .setInitialChannelCount(10)
+                .setMinRpcsPerChannel(1)
+                // Keep it conservative as we scale the channel size every 1min
+                // and delta is 2 channels.
+                .setMaxRpcsPerChannel(25)
+                .setPreemptiveRefreshEnabled(true)
+                .build())
+        .setMaxInboundMessageSize(MAX_MESSAGE_SIZE)
+        .setKeepAliveTime(Duration.ofSeconds(30)) // sends ping in this interval
+        .setKeepAliveTimeout(
+            Duration.ofSeconds(10)); // wait this long before considering the connection dead
   }
 
   /** Applies Direct Access traits to an existing builder. */