Made SpecificRow and types serializable by Kryo

apache · Aug 19, 2014 · c9e67de · c9e67de
1 parent 2b46c4b
commit c9e67de
Showing 1 changed file with 3 additions and 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
@@ -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 = {