Package uk.gov.gchq.gaffer.federated.simple.merge.operator

Class ElementAggregateOperator

java.lang.Object

uk.gov.gchq.gaffer.federated.simple.merge.operator.ElementAggregateOperator

All Implemented Interfaces:

BiFunction<Iterable<Element>,Iterable<Element>,Iterable<Element>>, BinaryOperator<Iterable<Element>>

public class ElementAggregateOperator
extends Object
implements BinaryOperator<Iterable<Element>>

Operator for aggregating two iterables of Elements together, this will ensure all properties for similar elements are merged using the ElementAggregator from the schema to perform the actual aggregation.

Constructor Summary

Constructors

Constructor	Description
ElementAggregateOperator()

Method Summary

Modifier and Type	Method	Description
Iterable<Element>	apply(Iterable<Element> update, Iterable<Element> state)
void	setSchema(Schema schema)	Set the schema to use for aggregating elements of the same group

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.BiFunction

andThen

Constructor Detail

ElementAggregateOperator

public ElementAggregateOperator()

Method Detail

setSchema

public void setSchema(Schema schema)

Set the schema to use for aggregating elements of the same group

Parameters:

schema - The schema.

apply

public Iterable<Element> apply(Iterable<Element> update,
                               Iterable<Element> state)

Specified by:

apply in interface BiFunction<Iterable<Element>,Iterable<Element>,Iterable<Element>>