Repository: spark
Updated Branches:
  refs/heads/branch-1.0 30be37ca7 -> f5399631c


[SPARK-1926] [SQL] Nullability of Max/Min/First should be true.

Nullability of `Max`/`Min`/`First` should be `true` because they return `null` 
if there are no rows.

Author: Takuya UESHIN <[email protected]>

Closes #881 from ueshin/issues/SPARK-1926 and squashes the following commits:

322610f [Takuya UESHIN] Fix nullability of Min/Max/First.

(cherry picked from commit d1375a2bff846f2c4274e14545924646852895f9)
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/f5399631
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/f5399631
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/f5399631

Branch: refs/heads/branch-1.0
Commit: f5399631ca8246e85f3b73d5f60ba1cdaab04ead
Parents: 30be37c
Author: Takuya UESHIN <[email protected]>
Authored: Tue May 27 14:53:57 2014 -0700
Committer: Reynold Xin <[email protected]>
Committed: Tue May 27 14:54:07 2014 -0700

----------------------------------------------------------------------
 .../org/apache/spark/sql/catalyst/expressions/aggregates.scala | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/f5399631/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala
----------------------------------------------------------------------
diff --git 
a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala
 
b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala
index 79937b1..b49a461 100644
--- 
a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala
+++ 
b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregates.scala
@@ -90,7 +90,7 @@ abstract class AggregateFunction
 
 case class Min(child: Expression) extends PartialAggregate with 
trees.UnaryNode[Expression] {
   override def references = child.references
-  override def nullable = child.nullable
+  override def nullable = true
   override def dataType = child.dataType
   override def toString = s"MIN($child)"
 
@@ -120,7 +120,7 @@ case class MinFunction(expr: Expression, base: 
AggregateExpression) extends Aggr
 
 case class Max(child: Expression) extends PartialAggregate with 
trees.UnaryNode[Expression] {
   override def references = child.references
-  override def nullable = child.nullable
+  override def nullable = true
   override def dataType = child.dataType
   override def toString = s"MAX($child)"
 
@@ -257,7 +257,7 @@ case class SumDistinct(child: Expression)
 
 case class First(child: Expression) extends PartialAggregate with 
trees.UnaryNode[Expression] {
   override def references = child.references
-  override def nullable = child.nullable
+  override def nullable = true
   override def dataType = child.dataType
   override def toString = s"FIRST($child)"
 

Reply via email to