spotless

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java

@@ -1494,10 +1494,10 @@ private PCollection<T> expandForDirectRead(
                   getProjectionPushdownApplied());
           List<? extends BoundedSource<T>> sources;
           try {
-            //This splitting logic taken from the SDF implementation of Read
+            // This splitting logic taken from the SDF implementation of Read
             long estimatedSize = source.getEstimatedSizeBytes(bqOptions);
-            // Split into pieces as close to the default desired bundle size but if that would cause too
-            // few splits then prefer to split up to the default desired number of splits.
+            // Split into pieces as close to the default desired bundle size but if that would cause
+            // too few splits then prefer to split up to the default desired number of splits.
             long desiredChunkSize;
             if (estimatedSize <= 0) {
               desiredChunkSize = 64 << 20; // 64mb

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOStorageQueryIT.java

@@ -147,9 +147,9 @@ public void testBigQueryStorageQueryWithErrorHandling1M() throws Exception {
 
     errorHandler.close();
 
-    //When 1/50 elements fail sequentially, this is the expected success count
+    // When 1/50 elements fail sequentially, this is the expected success count
     PAssert.thatSingleton(count).isEqualTo(10381L);
-    //this is the total elements, less the successful elements
+    // this is the total elements, less the successful elements
     PAssert.thatSingleton(errorHandler.getOutput()).isEqualTo(10592L - 10381L);
     p.run().waitUntilFinish();
   }

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigquery/BigQueryIOStorageReadIT.java

@@ -157,9 +157,9 @@ private void runBigQueryIOStorageReadPipelineErrorHandling() throws Exception {
 
     errorHandler.close();
 
-    //When 1/50 elements fail sequentially, this is the expected success count
+    // When 1/50 elements fail sequentially, this is the expected success count
     PAssert.thatSingleton(count).isEqualTo(10381L);
-    //this is the total elements, less the successful elements
+    // this is the total elements, less the successful elements
     PAssert.thatSingleton(errorHandler.getOutput()).isEqualTo(10592L - 10381L);
     p.run().waitUntilFinish();
   }