From c9e67dec15947c133fbe3813b71640f420315289 Mon Sep 17 00:00:00 2001 From: Gregory Owen Date: Mon, 18 Aug 2014 20:31:24 -0700 Subject: [PATCH] Made SpecificRow and types serializable by Kryo --- .../apache/spark/sql/catalyst/expressions/SpecificRow.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SpecificRow.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SpecificRow.scala index 2b0f351654774..cfb292a41dda7 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SpecificRow.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SpecificRow.scala @@ -57,7 +57,7 @@ s""" }.foreach(println) }}} */ -abstract class MutableValue { +abstract class MutableValue extends Serializable { var isNull: Boolean = true def boxed: Any def update(v: Any) @@ -197,6 +197,8 @@ class SpecificMutableRow(val values: Array[MutableValue]) extends MutableRow { case _ => new MutableAny }.toArray) + def this() = this(Seq.empty) + override def length: Int = values.length override def setNullAt(i: Int): Unit = {