[WIP][SPARK-2554][SQL] CountDistinct and SumDistinct should do partial aggregation

The code was missing, I just added it.
On Aug 20, 2014 3:18 PM, "Reynold Xin" <notifications@github.com> wrote:

> In
> sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/arithmetic.scala:
>
> > @@ -85,3 +85,21 @@ case class Remainder(left: Expression, right: Expression) extends BinaryArithmet
> >
> >    override def eval(input: Row): Any = i2(input, left, right, _.rem(_, _))
> >  }
> > +
> > +case class MaxOf(left: Expression, right: Expression) extends Expression {
> > +  type EvaluatedType = Any
> > +
> > +  override def nullable = left.nullable && right.nullable
> > +
> > +  override def children = left :: right :: Nil
> > +
> > +  override def references = (left.flatMap(_.references) ++ right.flatMap(_.references)).toSet
> > +
> > +  override def dataType = left.dataType
> > +
> > +  override def eval(input: Row): Any = {
> > +    val leftEval = left.eval(input)
>
> what do u mean?
>
> —
> Reply to this email directly or view it on GitHub
> <https://github.com/apache/spark/pull/1935/files#r16509768>.
>