Code simplification (GoogleCloudDataproc#1041)

suryasoma · Aug 16, 2023 · f55c0dc · f55c0dc
1 parent 977a0a7
commit f55c0dc
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/...ery-connector-common/src/main/java/com/google/cloud/spark/bigquery/SparkBigQueryUtil.java b/...ery-connector-common/src/main/java/com/google/cloud/spark/bigquery/SparkBigQueryUtil.java
@@ -43,7 +43,6 @@
 import org.apache.spark.sql.internal.SQLConf;
 import org.apache.spark.sql.sources.Filter;
 import org.apache.spark.sql.types.Metadata;
-import scala.collection.Iterator;
 
 /** Spark related utilities */
 public class SparkBigQueryUtil {
@@ -203,11 +202,7 @@ public static String getTableNameFromOptions(Map<String, String> options) {
   public static <K, V> ImmutableMap<K, V> scalaMapToJavaMap(
       scala.collection.immutable.Map<K, V> map) {
     ImmutableMap.Builder<K, V> result = ImmutableMap.<K, V>builder();
-    Iterator<K> keysIterator = map.keys().iterator();
-    while (keysIterator.hasNext()) {
-      K key = keysIterator.next();
-      result.put(key, map.get(key).get());
-    }
+    map.foreach(entry -> result.put(entry._1(), entry._2()));
     return result.build();
   }