TypedAggregateExpression Expression

TypedAggregateExpression is the contract for AggregateFunction expressions that…​FIXME

package org.apache.spark.sql.execution.aggregate

trait TypedAggregateExpression extends AggregateFunction {
  // only required methods that have no implementation
  def aggregator: Aggregator[Any, Any, Any]
  def inputClass: Option[Class[_]]
  def inputDeserializer: Option[Expression]
  def inputSchema: Option[StructType]
  def withInputInfo(deser: Expression, cls: Class[_], schema: StructType): TypedAggregateExpression
}

TypedAggregateExpression is used when:

Table 1. TypedAggregateExpression Contract
Method Description

aggregator

Aggregator

inputClass

Used when…​FIXME

inputDeserializer

Used when…​FIXME

inputSchema

Used when…​FIXME

withInputInfo

Used when…​FIXME

Table 2. TypedAggregateExpressions
Aggregator Description

ComplexTypedAggregateExpression

SimpleTypedAggregateExpression

Creating TypedAggregateExpression — apply Factory Method

apply[BUF : Encoder, OUT : Encoder](
  aggregator: Aggregator[_, BUF, OUT]): TypedAggregateExpression

apply…​FIXME

Note
apply is used exclusively when Aggregator is requested to convert itself to a TypedColumn.

results matching ""

    No results matching ""