From a070d44aa31a6af4cd8d45fc2c02adef61bb03b9 Mon Sep 17 00:00:00 2001 From: Reynold Xin Date: Wed, 8 Oct 2014 15:26:52 -0700 Subject: [PATCH] Fix line length in HashJoin --- .../scala/org/apache/spark/sql/execution/join/HashJoin.scala | 3 ++- 1 file changed, 2 insertions(+), 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 index 211076c098db3..9e379f2fb1fdc 100644 --- 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]]()