Skip to content

Commit 16f99c3

Browse files
yhuaiCodingCat
authored andcommitted
[SPARK-9777] [SQL] Window operator can accept UnsafeRows
https://issues.apache.org/jira/browse/SPARK-9777 Author: Yin Huai <[email protected]> Closes apache#8064 from yhuai/windowUnsafe and squashes the following commits: 8fb3537 [Yin Huai] Set canProcessUnsafeRows to true.
1 parent 90cc379 commit 16f99c3

File tree

1 file changed

+2
-0
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution

1 file changed

+2
-0
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -101,6 +101,8 @@ case class Window(
101101

102102
override def outputOrdering: Seq[SortOrder] = child.outputOrdering
103103

104+
override def canProcessUnsafeRows: Boolean = true
105+
104106
/**
105107
* Create a bound ordering object for a given frame type and offset. A bound ordering object is
106108
* used to determine which input row lies within the frame boundaries of an output row.

0 commit comments

Comments
 (0)