Repository: spark
Updated Branches:
  refs/heads/branch-1.5 0e0471db4 -> f75c64b0c


[SPARK-9777] [SQL] Window operator can accept UnsafeRows

https://issues.apache.org/jira/browse/SPARK-9777

Author: Yin Huai <[email protected]>

Closes #8064 from yhuai/windowUnsafe and squashes the following commits:

8fb3537 [Yin Huai] Set canProcessUnsafeRows to true.

(cherry picked from commit be80def0d07ed0f45d60453f4f82500d8c4c9106)
Signed-off-by: Reynold Xin <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/f75c64b0
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/f75c64b0
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/f75c64b0

Branch: refs/heads/branch-1.5
Commit: f75c64b0ca1f23ec44a8cf5a0ea82249a9f956dc
Parents: 0e0471d
Author: Yin Huai <[email protected]>
Authored: Sun Aug 9 22:33:53 2015 -0700
Committer: Reynold Xin <[email protected]>
Committed: Sun Aug 9 22:34:00 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/f75c64b0/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: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to