More style fixes.

apache · Jan 21, 2015 · b1a0f6a · b1a0f6a
1 parent 526c3b0
commit b1a0f6a
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/sql/core/src/test/scala/org/apache/spark/sql/sources/DDLTestSuite.scala b/sql/core/src/test/scala/org/apache/spark/sql/sources/DDLTestSuite.scala
@@ -24,8 +24,8 @@ class DDLScanSource extends RelationProvider {
   override def createRelation(
       sqlContext: SQLContext,
       parameters: Map[String, String]): BaseRelation = {
-      SimpleDDLScan(parameters("from").toInt, parameters("TO").toInt)(sqlContext)
-    }
+    SimpleDDLScan(parameters("from").toInt, parameters("TO").toInt)(sqlContext)
+  }
 }
 
 case class SimpleDDLScan(from: Int, to: Int)(@transient val sqlContext: SQLContext)
@@ -50,14 +50,15 @@ case class SimpleDDLScan(from: Int, to: Int)(@transient val sqlContext: SQLConte
       StructField("arrayType", ArrayType(StringType)),
       StructField("structType",
         StructType(StructField("f1",StringType) ::
-          (StructField("f2",IntegerType)) :: Nil
+          StructField("f2",IntegerType) :: Nil
         )
       )
     ))
 
 
-  override def buildScan() = sqlContext.sparkContext.parallelize(from to to).
-    map(e => Row(s"people$e",e*2))
+  override def buildScan() = sqlContext.sparkContext.parallelize(from to to).map { e =>
+    Row(s"people$e", e * 2)
+  }
 }
 
 class DDLTestSuite extends DataSourceTest {

diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveContext.scala
@@ -80,7 +80,7 @@ class HiveContext(sc: SparkContext) extends SQLContext(sc) {
       }
       new SchemaRDD(this, basicPlan)
     } else {
-      sys.error(s"Unsupported SQL dialect: ${conf.dialect}.  Try 'sql' or 'hiveql'")
+      sys.error(s"Unsupported SQL dialect: ${conf.dialect}. Try 'sql' or 'hiveql'")
     }
   }