move input parameters to the same line as map function

apache · Aug 20, 2018 · 9261beb · 9261beb
1 parent ce4c935
commit 9261beb
Showing 1 changed file with 9 additions and 10 deletions.
diff --git a/...rc/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetReadSupport.scala b/...rc/main/scala/org/apache/spark/sql/execution/datasources/parquet/ParquetReadSupport.scala
@@ -309,16 +309,15 @@ private[parquet] object ParquetReadSupport {
       structType.map { f =>
         caseInsensitiveParquetFieldMap
           .get(f.name.toLowerCase)
-          .map {
-            parquetTypes =>
-              if (parquetTypes.size > 1) {
-                // Need to fail if there is ambiguity, i.e. more than one field is matched
-                val parquetTypesString = parquetTypes.map(_.getName).mkString("[", ", ", "]")
-                throw new AnalysisException(s"""Found duplicate field(s) "${f.name}": """ +
-                  s"$parquetTypesString in case-insensitive mode")
-              } else {
-                clipParquetType(parquetTypes.head, f.dataType, caseSensitive)
-              }
+          .map { parquetTypes =>
+            if (parquetTypes.size > 1) {
+              // Need to fail if there is ambiguity, i.e. more than one field is matched
+              val parquetTypesString = parquetTypes.map(_.getName).mkString("[", ", ", "]")
+              throw new AnalysisException(s"""Found duplicate field(s) "${f.name}": """ +
+                s"$parquetTypesString in case-insensitive mode")
+            } else {
+              clipParquetType(parquetTypes.head, f.dataType, caseSensitive)
+            }
           }.getOrElse(toParquet.convertField(f))
       }
     }