Packages

package aggregates

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. trait AggregateFunctionImports extends AnyRef
  2. case class ExpressionAggregates(children: Seq[Expression], zero: (DataType) ⇒ Option[Any], addF: (DataType) ⇒ Option[(Expression, Expression) ⇒ Expression], sumType: DataType) extends DeclarativeAggregate with Product with Serializable

    Represents an aggregation expression built from a filter function, a sum lambda and an evaluate lambda which uses the count of filter hits and the sum as parameters.

  3. sealed trait ResultsExpression extends AnyRef
  4. case class ResultsWith(lambdaFunctionIn: org.apache.spark.sql.catalyst.expressions.LambdaFunction, name: String = "results_with") extends ResultsExpression with Product with Serializable
    Attributes
    protected[quality]
  5. sealed trait SumExpression extends AnyRef
  6. case class SumWith(lambdaFunctionIn: org.apache.spark.sql.catalyst.expressions.LambdaFunction, name: String = "sum_with") extends SumExpression with Product with Serializable
    Attributes
    protected[quality]
  7. case class SumWithMap(id: Column, lambdaFunctionIn: org.apache.spark.sql.catalyst.expressions.LambdaFunction, zero: (DataType) ⇒ Option[Any]) extends SumExpression with Product with Serializable
    Attributes
    protected[quality]

Value Members

  1. object AggregateExpressions

Ungrouped