Class FederatedResultAccumulator<T>
- java.lang.Object
-
- uk.gov.gchq.gaffer.federated.simple.merge.FederatedResultAccumulator<T>
-
- All Implemented Interfaces:
BiFunction<T,T,T>
,BinaryOperator<T>
- Direct Known Subclasses:
DefaultResultAccumulator
public abstract class FederatedResultAccumulator<T> extends Object implements BinaryOperator<T>
Abstract base class for accumulators that merge results from multiple graphs together. Has default operators set for common data types.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
aggregateElements()
Access to see if this accumulator is set to try element aggregation or not.void
setAggregateElements(boolean aggregateElements)
Set whether the element aggregation operator should be used.void
setSchema(Schema schema)
Sets the schema to use for theElementAggregateOperator
.-
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, apply
-
-
-
-
Method Detail
-
setAggregateElements
public void setAggregateElements(boolean aggregateElements)
Set whether the element aggregation operator should be used. This will attempt to aggregate elements based on the current schema.- Parameters:
aggregateElements
- should elements be aggregated.
-
aggregateElements
public boolean aggregateElements()
Access to see if this accumulator is set to try element aggregation or not.- Returns:
- Is aggregation set.
-
setSchema
public void setSchema(Schema schema)
Sets the schema to use for theElementAggregateOperator
.- Parameters:
schema
- The schema.
-
-