Package it.bancaditalia.oss.vtl.impl.environment.spark

Class AnalyticAggregator<A>

java.lang.Object

org.apache.spark.sql.expressions.Aggregator<Serializable,A,Serializable>

it.bancaditalia.oss.vtl.impl.environment.spark.AnalyticAggregator<A>

All Implemented Interfaces:

Serializable, scala.Serializable

public class AnalyticAggregator<A>
extends org.apache.spark.sql.expressions.Aggregator<Serializable,A,Serializable>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
AnalyticAggregator(DataStructureComponent<?,?,?> oldMeasure, DataStructureComponent<?,?,?> newMeasure, SerCollector<ScalarValue<?,?,?,?>,?,A> collector, org.apache.spark.sql.SparkSession session)

Method Summary

Modifier and Type	Method	Description
org.apache.spark.sql.Encoder<A>	bufferEncoder()
Serializable	finish(A reduction)
A	merge(A acc1, A acc2)
org.apache.spark.sql.Encoder<Serializable>	outputEncoder()
A	reduce(A acc, Serializable value)
String	toString()
A	zero()

Methods inherited from class org.apache.spark.sql.expressions.Aggregator

toColumn

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AnalyticAggregator

public AnalyticAggregator(DataStructureComponent<?,?,?> oldMeasure,
                          DataStructureComponent<?,?,?> newMeasure,
                          SerCollector<ScalarValue<?,?,?,?>,?,A> collector,
                          org.apache.spark.sql.SparkSession session)

Method Detail

zero

public A zero()

Specified by:

zero in class org.apache.spark.sql.expressions.Aggregator<Serializable,A,Serializable>

bufferEncoder

public org.apache.spark.sql.Encoder<A> bufferEncoder()

Specified by:

bufferEncoder in class org.apache.spark.sql.expressions.Aggregator<Serializable,A,Serializable>

reduce

public A reduce(A acc,
                Serializable value)

Specified by:

reduce in class org.apache.spark.sql.expressions.Aggregator<Serializable,A,Serializable>

merge

public A merge(A acc1,
               A acc2)

Specified by:

merge in class org.apache.spark.sql.expressions.Aggregator<Serializable,A,Serializable>

finish

public Serializable finish(A reduction)

Specified by:

finish in class org.apache.spark.sql.expressions.Aggregator<Serializable,A,Serializable>

outputEncoder

public org.apache.spark.sql.Encoder<Serializable> outputEncoder()

Specified by:

outputEncoder in class org.apache.spark.sql.expressions.Aggregator<Serializable,A,Serializable>

toString

public String toString()

Overrides:

toString in class Object