We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a39be8c commit a070d44Copy full SHA for a070d44
sql/core/src/main/scala/org/apache/spark/sql/execution/join/HashJoin.scala
@@ -47,7 +47,8 @@ trait HashJoin {
47
@transient protected lazy val streamSideKeyGenerator =
48
newMutableProjection(streamedKeys, streamedPlan.output)
49
50
- protected def joinIterators(buildIter: Iterator[Row], streamIter: Iterator[Row]): Iterator[Row] = {
+ protected def joinIterators(buildIter: Iterator[Row], streamIter: Iterator[Row]): Iterator[Row] =
51
+ {
52
// TODO: Use Spark's HashMap implementation.
53
54
val hashTable = new java.util.HashMap[Row, CompactBuffer[Row]]()
0 commit comments