Skip to content

Commit 3868f6c

Browse files
committed
Merge pull request #9 from GregOwen/countDistinctPartial
Made SpecificRow and types serializable by Kryo
2 parents 2b46c4b + c9e67de commit 3868f6c

File tree

1 file changed

+3
-1
lines changed
  • sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions

1 file changed

+3
-1
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/SpecificRow.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ s"""
5757
}.foreach(println)
5858
}}}
5959
*/
60-
abstract class MutableValue {
60+
abstract class MutableValue extends Serializable {
6161
var isNull: Boolean = true
6262
def boxed: Any
6363
def update(v: Any)
@@ -197,6 +197,8 @@ class SpecificMutableRow(val values: Array[MutableValue]) extends MutableRow {
197197
case _ => new MutableAny
198198
}.toArray)
199199

200+
def this() = this(Seq.empty)
201+
200202
override def length: Int = values.length
201203

202204
override def setNullAt(i: Int): Unit = {

0 commit comments

Comments
 (0)