Skip to content

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]][initialize] | <> and puts it at[mutableAggBufferOffset] position in the input InternalRow.

[[inputAggBufferAttributes]] inputAggBufferAttributes

[[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 <>

[[deserialize]] deserialize
[[eval]] eval
[[merge]] merge
[[serialize]] serialize
[[update]] update

Last update: 2020-10-21