kotlin-spark-api_3.3.2_2.13/org.jetbrains.kotlinx.spark.api/Aggregator

Aggregator

class Aggregator<IN, BUF, OUT>( zero: () -> BUF, reduce: (b: BUF, a: IN) -> BUF, merge: (b1: BUF, b2: BUF) -> BUF, finish: (reduction: BUF) -> OUT, bufferEncoder: Encoder<BUF>, outputEncoder: Encoder<OUT>) : Aggregator<IN, BUF, OUT> , Serializable

Constructors

Aggregator

constructor( zero: () -> BUF, reduce: (b: BUF, a: IN) -> BUF, merge: (b1: BUF, b2: BUF) -> BUF, finish: (reduction: BUF) -> OUT, bufferEncoder: Encoder<BUF>, outputEncoder: Encoder<OUT>)

Functions

bufferEncoder

open override fun bufferEncoder(): Encoder<BUF>

finish

open override fun finish(reduction: BUF): OUT

merge

open override fun merge(b1: BUF, b2: BUF): BUF

outputEncoder

open override fun outputEncoder(): Encoder<OUT>

reduce

open override fun reduce(b: BUF, a: IN): BUF

toColumn

open fun toColumn(): TypedColumn<IN, OUT>

zero

open override fun zero(): BUF