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

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