Package uk.gov.gchq.gaffer.sketches.datasketches.sampling.binaryoperator

Class ReservoirItemsUnionAggregator<T>

java.lang.Object

uk.gov.gchq.koryphe.binaryoperator.KorypheBinaryOperator<org.apache.datasketches.sampling.ReservoirItemsUnion<T>>

uk.gov.gchq.gaffer.sketches.datasketches.sampling.binaryoperator.ReservoirItemsUnionAggregator<T>

Type Parameters:

T - The type of object in the reservoir.

All Implemented Interfaces:

BiFunction<org.apache.datasketches.sampling.ReservoirItemsUnion<T>,org.apache.datasketches.sampling.ReservoirItemsUnion<T>,org.apache.datasketches.sampling.ReservoirItemsUnion<T>>, BinaryOperator<org.apache.datasketches.sampling.ReservoirItemsUnion<T>>

public class ReservoirItemsUnionAggregator<T>
extends uk.gov.gchq.koryphe.binaryoperator.KorypheBinaryOperator<org.apache.datasketches.sampling.ReservoirItemsUnion<T>>

A ReservoirItemsUnionAggregator is a BinaryOperator that aggregates ReservoirItemsUnions. It does this by extracting a ReservoirItemsSketch from each ReservoirItemsUnion and merges that using ReservoirItemsUnion.update(org.apache.datasketches.sampling.ReservoirItemsSketch).

Constructor Summary

Constructors

Constructor	Description
ReservoirItemsUnionAggregator()

Method Summary

Modifier and Type	Method	Description
org.apache.datasketches.sampling.ReservoirItemsUnion<T>	_apply(org.apache.datasketches.sampling.ReservoirItemsUnion<T> a, org.apache.datasketches.sampling.ReservoirItemsUnion<T> b)

Methods inherited from class uk.gov.gchq.koryphe.binaryoperator.KorypheBinaryOperator

apply, equals, hashCode

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiFunction

andThen

Constructor Detail

ReservoirItemsUnionAggregator

public ReservoirItemsUnionAggregator()

Method Detail

_apply

public org.apache.datasketches.sampling.ReservoirItemsUnion<T> _apply(org.apache.datasketches.sampling.ReservoirItemsUnion<T> a,
                                                                      org.apache.datasketches.sampling.ReservoirItemsUnion<T> b)