diff options
| author | Wenchen Fan <cloud0fan@outlook.com> | 2015-06-24 16:26:00 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2015-06-24 16:26:00 -0700 |
| commit | b71d3254e50838ccae43bdb0ff186fda25f03152 (patch) | |
| tree | 9a22820e88da2970e4144cb8f82db9309ef38a9f /sql/core | |
| parent | 7daa70292e47be6a944351ef00c770ad4bcb0877 (diff) | |
| download | spark-b71d3254e50838ccae43bdb0ff186fda25f03152.tar.gz spark-b71d3254e50838ccae43bdb0ff186fda25f03152.tar.bz2 spark-b71d3254e50838ccae43bdb0ff186fda25f03152.zip | |
[SPARK-8075] [SQL] apply type check interface to more expressions
a follow up of https://github.com/apache/spark/pull/6405.
Note: It's not a big change, a lot of changing is due to I swap some code in `aggregates.scala` to make aggregate functions right below its corresponding aggregate expressions.
Author: Wenchen Fan <cloud0fan@outlook.com>
Closes #6723 from cloud-fan/type-check and squashes the following commits:
2124301 [Wenchen Fan] fix tests
5a658bb [Wenchen Fan] add tests
287d3bb [Wenchen Fan] apply type check interface to more expressions
Diffstat (limited to 'sql/core')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/pythonUdfs.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/pythonUdfs.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/pythonUdfs.scala index 6db551c543..f9c3fe92c2 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/pythonUdfs.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/pythonUdfs.scala @@ -55,7 +55,7 @@ private[spark] case class PythonUDF( override def toString: String = s"PythonUDF#$name(${children.mkString(",")})" - def nullable: Boolean = true + override def nullable: Boolean = true override def eval(input: InternalRow): Any = { throw new UnsupportedOperationException("PythonUDFs can not be directly evaluated.") |