Skip to content
Snippets Groups Projects
Commit 4413d085 authored by Yin Huai's avatar Yin Huai Committed by Reynold Xin
Browse files

[SPARK-9908] [SQL] When spark.sql.tungsten.enabled is false, broadcast join does not work

https://issues.apache.org/jira/browse/SPARK-9908

Author: Yin Huai <yhuai@databricks.com>

Closes #8149 from yhuai/SPARK-9908.
parent 7c35746c
No related branches found
No related tags found
No related merge requests found
......@@ -66,7 +66,8 @@ private[joins] final class GeneralHashedRelation(
private var hashTable: JavaHashMap[InternalRow, CompactBuffer[InternalRow]])
extends HashedRelation with Externalizable {
private def this() = this(null) // Needed for serialization
// Needed for serialization (it is public to make Java serialization work)
def this() = this(null)
override def get(key: InternalRow): Seq[InternalRow] = hashTable.get(key)
......@@ -88,7 +89,8 @@ private[joins]
final class UniqueKeyHashedRelation(private var hashTable: JavaHashMap[InternalRow, InternalRow])
extends HashedRelation with Externalizable {
private def this() = this(null) // Needed for serialization
// Needed for serialization (it is public to make Java serialization work)
def this() = this(null)
override def get(key: InternalRow): Seq[InternalRow] = {
val v = hashTable.get(key)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment