You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2015/08/10 07:33:57 UTC
spark git commit: [SPARK-9777] [SQL] Window operator can accept
UnsafeRows
Repository: spark
Updated Branches:
refs/heads/master 46025616b -> be80def0d
[SPARK-9777] [SQL] Window operator can accept UnsafeRows
https://issues.apache.org/jira/browse/SPARK-9777
Author: Yin Huai <yh...@databricks.com>
Closes #8064 from yhuai/windowUnsafe and squashes the following commits:
8fb3537 [Yin Huai] Set canProcessUnsafeRows to true.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/be80def0
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/be80def0
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/be80def0
Branch: refs/heads/master
Commit: be80def0d07ed0f45d60453f4f82500d8c4c9106
Parents: 4602561
Author: Yin Huai <yh...@databricks.com>
Authored: Sun Aug 9 22:33:53 2015 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Sun Aug 9 22:33:53 2015 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/sql/execution/Window.scala | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/be80def0/sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala
index fe9f2c7..0269d6d 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala
@@ -101,6 +101,8 @@ case class Window(
override def outputOrdering: Seq[SortOrder] = child.outputOrdering
+ override def canProcessUnsafeRows: Boolean = true
+
/**
* Create a bound ordering object for a given frame type and offset. A bound ordering object is
* used to determine which input row lies within the frame boundaries of an output row.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org