Fix line length in HashJoin

jkbradley · Oct 8, 2014 · a070d44 · a070d44
1 parent a39be8c
commit a070d44
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/join/HashJoin.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/join/HashJoin.scala
@@ -47,7 +47,8 @@ trait HashJoin {
   @transient protected lazy val streamSideKeyGenerator =
     newMutableProjection(streamedKeys, streamedPlan.output)
 
-  protected def joinIterators(buildIter: Iterator[Row], streamIter: Iterator[Row]): Iterator[Row] = {
+  protected def joinIterators(buildIter: Iterator[Row], streamIter: Iterator[Row]): Iterator[Row] =
+  {
     // TODO: Use Spark's HashMap implementation.
 
     val hashTable = new java.util.HashMap[Row, CompactBuffer[Row]]()