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
[[aggBufferAttributes]] aggBufferAttributes
[[aggBufferSchema]] aggBufferSchema
| [[initialize]] spark-sql-Expression-ImperativeAggregate.md#initialize[initialize] | <> and puts it at spark-sql-Expression-ImperativeAggregate.md#mutableAggBufferOffset[mutableAggBufferOffset] position in the input InternalRow .
[[inputAggBufferAttributes]] inputAggBufferAttributes ===
[[implementations]] .TypedImperativeAggregate's Direct Implementations [width="100%",cols="1,2",options="header"] |=== | Name | Description
ComplexTypedAggregateExpression
=== [[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 <>
[[deserialize]] deserialize