You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2014/11/18 01:30:06 UTC
spark git commit: [SQL] Construct the MutableRow from an Array
Repository: spark
Updated Branches:
refs/heads/master 566c79193 -> 69e858cc7
[SQL] Construct the MutableRow from an Array
Author: Cheng Hao <ha...@intel.com>
Closes #3217 from chenghao-intel/mutablerow and squashes the following commits:
e8a10bd [Cheng Hao] revert the change of Row object
4681aea [Cheng Hao] Add toMutableRow method in object Row
a751838 [Cheng Hao] Construct the MutableRow from an existed row
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/69e858cc
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/69e858cc
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/69e858cc
Branch: refs/heads/master
Commit: 69e858cc7748b6babadd0cbe20e65f3982161cbf
Parents: 566c791
Author: Cheng Hao <ha...@intel.com>
Authored: Mon Nov 17 16:29:52 2014 -0800
Committer: Michael Armbrust <mi...@databricks.com>
Committed: Mon Nov 17 16:29:52 2014 -0800
----------------------------------------------------------------------
.../scala/org/apache/spark/sql/catalyst/expressions/Row.scala | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/69e858cc/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Row.scala
----------------------------------------------------------------------
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Row.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Row.scala
index d00ec39..463f366 100644
--- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Row.scala
+++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/Row.scala
@@ -215,9 +215,11 @@ class GenericRow(protected[sql] val values: Array[Any]) extends Row {
def copy() = this
}
-class GenericMutableRow(size: Int) extends GenericRow(size) with MutableRow {
+class GenericMutableRow(v: Array[Any]) extends GenericRow(v) with MutableRow {
/** No-arg constructor for serialization. */
- def this() = this(0)
+ def this() = this(null)
+
+ def this(size: Int) = this(new Array[Any](size))
override def setBoolean(ordinal: Int, value: Boolean): Unit = { values(ordinal) = value }
override def setByte(ordinal: Int, value: Byte): Unit = { values(ordinal) = value }
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org