diff options
| author | Yin Huai <yhuai@databricks.com> | 2015-08-09 22:33:53 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-08-09 22:33:53 -0700 |
| commit | be80def0d07ed0f45d60453f4f82500d8c4c9106 (patch) | |
| tree | 3365a62d76a92097693ee2a5919d02313be3ff58 /sql | |
| parent | 46025616b414eaf1da01fcc1255d8041ea1554bc (diff) | |
| download | spark-be80def0d07ed0f45d60453f4f82500d8c4c9106.tar.gz spark-be80def0d07ed0f45d60453f4f82500d8c4c9106.tar.bz2 spark-be80def0d07ed0f45d60453f4f82500d8c4c9106.zip | |
[SPARK-9777] [SQL] Window operator can accept UnsafeRows
https://issues.apache.org/jira/browse/SPARK-9777
Author: Yin Huai <yhuai@databricks.com>
Closes #8064 from yhuai/windowUnsafe and squashes the following commits:
8fb3537 [Yin Huai] Set canProcessUnsafeRows to true.
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/Window.scala | 2 |
1 files changed, 2 insertions, 0 deletions
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 fe9f2c7028..0269d6d4b7 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. |