Skip to content

Commit a070d44

Browse files
committed
Fix line length in HashJoin
1 parent a39be8c commit a070d44

File tree

1 file changed

+2
-1
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/join

1 file changed

+2
-1
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/join/HashJoin.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,8 @@ trait HashJoin {
4747
@transient protected lazy val streamSideKeyGenerator =
4848
newMutableProjection(streamedKeys, streamedPlan.output)
4949

50-
protected def joinIterators(buildIter: Iterator[Row], streamIter: Iterator[Row]): Iterator[Row] = {
50+
protected def joinIterators(buildIter: Iterator[Row], streamIter: Iterator[Row]): Iterator[Row] =
51+
{
5152
// TODO: Use Spark's HashMap implementation.
5253

5354
val hashTable = new java.util.HashMap[Row, CompactBuffer[Row]]()

0 commit comments

Comments
 (0)