From fb463925f5fc4917979efe84fadbdfe393e71053 Mon Sep 17 00:00:00 2001 From: Michael Armbrust Date: Fri, 3 Jul 2015 12:02:12 -0700 Subject: [PATCH] [SPARK-5707][SQL] Avoid codegen for HashedRelation keys --- .../scala/org/apache/spark/sql/execution/joins/HashJoin.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala index 3a4196a90d14a..64dd9cf02feb9 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/joins/HashJoin.scala @@ -44,7 +44,7 @@ trait HashJoin { override def output: Seq[Attribute] = left.output ++ right.output @transient protected lazy val buildSideKeyGenerator: Projection = - newProjection(buildKeys, buildPlan.output) + new InterpretedProjection(buildKeys, buildPlan.output) @transient protected lazy val streamSideKeyGenerator: () => MutableProjection = newMutableProjection(streamedKeys, streamedPlan.output)