Fix style

sql/core/src/test/scala/org/apache/spark/sql/execution/datasources/json/JsonSuite.scala

@@ -304,7 +304,8 @@ class JsonSuite extends QueryTest with SQLTestUtils with TestJsonData {
 
     // Access elements of a BigInteger array (we use DecimalType internally).
     checkAnswer(
-      ctx.sql("select arrayOfBigInteger[0], arrayOfBigInteger[1], arrayOfBigInteger[2] from jsonTable"),
+      ctx.sql(
+        "select arrayOfBigInteger[0], arrayOfBigInteger[1], arrayOfBigInteger[2] from jsonTable"),
       Row(new java.math.BigDecimal("922337203685477580700"),
         new java.math.BigDecimal("-922337203685477580800"), null)
     )
@@ -355,7 +356,8 @@ class JsonSuite extends QueryTest with SQLTestUtils with TestJsonData {
 
     // Access elements of an array field of a struct.
     checkAnswer(
-      ctx.sql("select structWithArrayFields.field1[1], structWithArrayFields.field2[3] from jsonTable"),
+      ctx.sql(
+        "select structWithArrayFields.field1[1], structWithArrayFields.field2[3] from jsonTable"),
       Row(5, null)
     )
   }
@@ -590,7 +592,8 @@ class JsonSuite extends QueryTest with SQLTestUtils with TestJsonData {
 
     val schema = StructType(StructField("a", LongType, true) :: Nil)
     val logicalRelation =
-      _sqlContext.read.schema(schema).json(path).queryExecution.analyzed.asInstanceOf[LogicalRelation]
+      _sqlContext.read.schema(schema).json(path)
+        .queryExecution.analyzed.asInstanceOf[LogicalRelation]
     val relationWithSchema = logicalRelation.relation.asInstanceOf[JSONRelation]
     assert(relationWithSchema.paths === Array(path))
     assert(relationWithSchema.schema === schema)
@@ -1021,7 +1024,8 @@ class JsonSuite extends QueryTest with SQLTestUtils with TestJsonData {
 
     // Access an array field of a struct.
     checkAnswer(
-      ctx.sql("select structWithArrayFields.field1, structWithArrayFields.field2 from complexTable"),
+      ctx.sql(
+        "select structWithArrayFields.field1, structWithArrayFields.field2 from complexTable"),
       Row(Seq(4, 5, 6), Seq("str1", "str2"))
     )
 

sql/core/src/test/scala/org/apache/spark/sql/jdbc/JDBCSuite.scala

@@ -185,19 +185,22 @@ class JDBCSuite extends SparkFunSuite with BeforeAndAfter with SQLTestUtils {
   }
 
   test("SELECT * WHERE (quoted strings)") {
-    assert(ctx.sql("select * from foobar").where('NAME === "joe 'foo' \"bar\"").collect().size === 1)
+    assert(
+      ctx.sql("select * from foobar").where('NAME === "joe 'foo' \"bar\"").collect().size === 1)
   }
 
   test("SELECT first field") {
-    val names = ctx.sql("SELECT NAME FROM foobar").collect().map(x => x.getString(0)).sortWith(_ < _)
+    val names =
+      ctx.sql("SELECT NAME FROM foobar").collect().map(x => x.getString(0)).sortWith(_ < _)
     assert(names.size === 3)
     assert(names(0).equals("fred"))
     assert(names(1).equals("joe 'foo' \"bar\""))
     assert(names(2).equals("mary"))
   }
 
   test("SELECT first field when fetchSize is two") {
-    val names = ctx.sql("SELECT NAME FROM fetchtwo").collect().map(x => x.getString(0)).sortWith(_ < _)
+    val names =
+      ctx.sql("SELECT NAME FROM fetchtwo").collect().map(x => x.getString(0)).sortWith(_ < _)
     assert(names.size === 3)
     assert(names(0).equals("fred"))
     assert(names(1).equals("joe 'foo' \"bar\""))

sql/core/src/test/scala/org/apache/spark/sql/sources/InsertSuite.scala

@@ -219,9 +219,10 @@ class InsertSuite extends DataSourceTest with BeforeAndAfterAll {
       caseInsensitiveContext.sql("SELECT a * 2 FROM jsonTable"),
       (1 to 10).map(i => Row(i * 2)).toSeq)
 
-    assertCached(caseInsensitiveContext.sql("SELECT x.a, y.a FROM jsonTable x JOIN jsonTable y ON x.a = y.a + 1"), 2)
-    checkAnswer(
-      caseInsensitiveContext.sql("SELECT x.a, y.a FROM jsonTable x JOIN jsonTable y ON x.a = y.a + 1"),
+    assertCached(caseInsensitiveContext.sql(
+      "SELECT x.a, y.a FROM jsonTable x JOIN jsonTable y ON x.a = y.a + 1"), 2)
+    checkAnswer(caseInsensitiveContext.sql(
+      "SELECT x.a, y.a FROM jsonTable x JOIN jsonTable y ON x.a = y.a + 1"),
       (2 to 10).map(i => Row(i, i - 1)).toSeq)
 
     // Insert overwrite and keep the same schema.

sql/core/src/test/scala/org/apache/spark/sql/sources/TableScanSuite.scala

@@ -301,9 +301,10 @@ class TableScanSuite extends DataSourceTest {
       caseInsensitiveContext.sql("SELECT i * 2 FROM oneToTen"),
       (1 to 10).map(i => Row(i * 2)).toSeq)
 
-    assertCached(caseInsensitiveContext.sql("SELECT a.i, b.i FROM oneToTen a JOIN oneToTen b ON a.i = b.i + 1"), 2)
-    checkAnswer(
-      caseInsensitiveContext.sql("SELECT a.i, b.i FROM oneToTen a JOIN oneToTen b ON a.i = b.i + 1"),
+    assertCached(caseInsensitiveContext.sql(
+      "SELECT a.i, b.i FROM oneToTen a JOIN oneToTen b ON a.i = b.i + 1"), 2)
+    checkAnswer(caseInsensitiveContext.sql(
+      "SELECT a.i, b.i FROM oneToTen a JOIN oneToTen b ON a.i = b.i + 1"),
       (2 to 10).map(i => Row(i, i - 1)).toSeq)
 
     // Verify uncaching

sql/hive/src/test/scala/org/apache/spark/sql/hive/QueryPartitionSuite.scala

@@ -1,4 +1,3 @@
-
 /*
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveExplainSuite.scala

@@ -47,7 +47,9 @@ class HiveExplainSuite extends QueryTest with HiveTestUtils {
                    "Limit",
                    "src")
 
-    checkExistence(ctx.sql("explain extended create table temp__b as select * from src limit 2"), true,
+    checkExistence(ctx.sql(
+        "explain extended create table temp__b as select * from src limit 2"),
+      true,
       "== Parsed Logical Plan ==",
       "== Analyzed Logical Plan ==",
       "== Optimized Logical Plan ==",

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveQuerySuite.scala

@@ -726,7 +726,8 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter {
         .size == 5)
 
     assert(
-      ctx.sql("select a, b from (select stack(2, key, value, key, value) as (a, b) from src) t limit 5")
+      ctx.sql(
+        "select a, b from (select stack(2, key, value, key, value) as (a, b) from src) t limit 5")
         .collect()
         .size == 5)
   }
@@ -773,7 +774,8 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter {
   }
 
   test("DESCRIBE commands") {
-    ctx.sql(s"CREATE TABLE test_describe_commands1 (key INT, value STRING) PARTITIONED BY (dt STRING)")
+    ctx.sql(
+      s"CREATE TABLE test_describe_commands1 (key INT, value STRING) PARTITIONED BY (dt STRING)")
 
     ctx.sql(
       """FROM src INSERT OVERWRITE TABLE test_describe_commands1 PARTITION (dt='2008-06-08')
@@ -935,7 +937,8 @@ class HiveQuerySuite extends HiveComparisonTest with BeforeAndAfter {
 
   ignore("Dynamic partition folder layout") {
     ctx.sql("DROP TABLE IF EXISTS dynamic_part_table")
-    ctx.sql("CREATE TABLE dynamic_part_table(intcol INT) PARTITIONED BY (partcol1 INT, partcol2 INT)")
+    ctx.sql(
+      "CREATE TABLE dynamic_part_table(intcol INT) PARTITIONED BY (partcol1 INT, partcol2 INT)")
     ctx.sql("SET hive.exec.dynamic.partition.mode=nonstrict")
 
     val data = Map(

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/HiveUDFSuite.scala

@@ -176,7 +176,8 @@ class HiveUDFSuite extends QueryTest with HiveTestUtils {
     val testData = ctx.sparkContext.parallelize(StringCaseClass("") :: Nil).toDF()
     testData.registerTempTable("inputTable")
 
-    ctx.sql(s"CREATE TEMPORARY FUNCTION testUDFToListString AS '${classOf[UDFToListString].getName}'")
+    ctx.sql(
+      s"CREATE TEMPORARY FUNCTION testUDFToListString AS '${classOf[UDFToListString].getName}'")
     val errMsg = intercept[AnalysisException] {
       ctx.sql("SELECT testUDFToListString(s) FROM inputTable")
     }
@@ -270,7 +271,8 @@ class HiveUDFSuite extends QueryTest with HiveTestUtils {
       StringCaseClass("world") :: StringCaseClass("goodbye") :: Nil).toDF()
     testData.registerTempTable("stringTable")
 
-    ctx.sql(s"CREATE TEMPORARY FUNCTION testStringStringUDF AS '${classOf[UDFStringString].getName}'")
+    ctx.sql(
+      s"CREATE TEMPORARY FUNCTION testStringStringUDF AS '${classOf[UDFStringString].getName}'")
     checkAnswer(
       ctx.sql("SELECT testStringStringUDF(\"hello\", s) FROM stringTable"),
       Seq(Row("hello world"), Row("hello goodbye")))

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/PruningSuite.scala

@@ -28,9 +28,9 @@ class PruningSuite extends HiveComparisonTest {
   protected override def beforeAll(): Unit = {
     super.beforeAll()
     ctx.cacheTables = false
-    // Column/partition pruning is not implemented for `InMemoryColumnarTableScan` yet, need to reset
-    // the environment to ensure all referenced tables in this suites are not cached in-memory.
-    // Refer to https://issues.apache.org/jira/browse/SPARK-2283 for details.
+    // Column/partition pruning is not implemented for `InMemoryColumnarTableScan` yet, need
+    // to reset the environment to ensure all referenced tables in this suites are not cached
+    // in-memory. Refer to https://issues.apache.org/jira/browse/SPARK-2283 for details.
     ctx.reset()
   }
 

sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/SQLQuerySuite.scala

@@ -312,15 +312,16 @@ class SQLQuerySuite extends QueryTest with HiveTestUtils {
       checkRelation("ctas1", true)
       ctx.sql("DROP TABLE ctas1")
 
-      ctx.sql("CREATE TABLE ctas1 stored as rcfile AS SELECT key k, value FROM src ORDER BY k, value")
+      ctx.sql(
+        "CREATE TABLE ctas1 stored as rcfile AS SELECT key k, value FROM src ORDER BY k, value")
       checkRelation("ctas1", false)
       ctx.sql("DROP TABLE ctas1")
 
       ctx.sql("CREATE TABLE ctas1 stored as orc AS SELECT key k, value FROM src ORDER BY k, value")
       checkRelation("ctas1", false)
       ctx.sql("DROP TABLE ctas1")
-
-      ctx.sql("CREATE TABLE ctas1 stored as parquet AS SELECT key k, value FROM src ORDER BY k, value")
+      ctx.sql(
+        "CREATE TABLE ctas1 stored as parquet AS SELECT key k, value FROM src ORDER BY k, value")
       checkRelation("ctas1", false)
       ctx.sql("DROP TABLE ctas1")
     } finally {
@@ -636,7 +637,8 @@ class SQLQuerySuite extends QueryTest with HiveTestUtils {
   }
 
   test("SPARK-4296 Grouping field with Hive UDF as sub expression") {
-    val rdd = ctx.sparkContext.makeRDD( """{"a": "str", "b":"1", "c":"1970-01-01 00:00:00"}""" :: Nil)
+    val rdd = ctx.sparkContext.makeRDD(
+      """{"a": "str", "b":"1", "c":"1970-01-01 00:00:00"}""" :: Nil)
     ctx.read.json(rdd).registerTempTable("data")
     checkAnswer(
       ctx.sql("SELECT concat(a, '-', b), year(c) FROM data GROUP BY concat(a, '-', b), year(c)"),