spotless

GoogleCloudDataproc · Oct 17, 2024 · fddf255 · fddf255
1 parent d7497b8
commit fddf255
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...main/java/com/google/cloud/spark/bigquery/v2/context/BigQueryDataSourceReaderContext.java b/...main/java/com/google/cloud/spark/bigquery/v2/context/BigQueryDataSourceReaderContext.java
@@ -339,7 +339,9 @@ private ReadSessionResponse createReadSession() {
 
   Stream<InputPartitionContext<InternalRow>> createEmptyProjectionPartitions() {
     Optional<String> filter = getCombinedFilter();
-    long rowCount = bigQueryClient.calculateTableSize(tableId, filter, readSessionCreatorConfig.getSnapshotTimeMillis());
+    long rowCount =
+        bigQueryClient.calculateTableSize(
+            tableId, filter, readSessionCreatorConfig.getSnapshotTimeMillis());
     logger.info("Used optimized BQ count(*) path. Count: " + rowCount);
     int partitionsCount = readSessionCreatorConfig.getDefaultParallelism();
     int partitionSize = (int) (rowCount / partitionsCount);