TypedImperativeAggregate — Imperative Aggregate Functions with Custom Aggregation Buffer¶

TypedImperativeAggregate is the <> for imperative aggregation functions that allows for an arbitrary user-defined java object to be used as <>.

[[ImperativeAggregate]] .TypedImperativeAggregate as ImperativeAggregate [cols="1,2",options="header",width="100%"] |=== | ImperativeAggregate Method | Description

| [[initialize]] spark-sql-Expression-ImperativeAggregate.md#initialize[initialize] | <> and puts it at spark-sql-Expression-ImperativeAggregate.md#mutableAggBufferOffset[mutableAggBufferOffset] position in the input InternalRow.

[[implementations]] .TypedImperativeAggregate's Direct Implementations [width="100%",cols="1,2",options="header"] |=== | Name | Description

=== [[contract]] TypedImperativeAggregate Contract

[source, scala]¶

package org.apache.spark.sql.catalyst.expressions.aggregate

abstract class TypedImperativeAggregate[T] extends ImperativeAggregate { def createAggregationBuffer(): T def deserialize(storageFormat: Array[Byte]): T def eval(buffer: T): Any def merge(buffer: T, input: T): T def serialize(buffer: T): Array[Byte] def update(buffer: T, input: InternalRow): T }

.TypedImperativeAggregate Contract [cols="1,2",options="header",width="100%"] |=== | Method | Description

| [[createAggregationBuffer]] createAggregationBuffer | Used exclusively when a TypedImperativeAggregate is <>