Package com.tangosol.util
Interface InvocableMap.ParallelAwareAggregator<K,V,P,R>
-
- Type Parameters:
K
- the type of the Map entry keysV
- the type of the Map entry valuesP
- the type of the intermediate result during the parallel stageR
- the type of the value returned by the ParallelAwareAggregator
- All Superinterfaces:
InvocableMap.EntryAggregator<K,V,R>
,Serializable
- Enclosing interface:
- InvocableMap<K,V>
@Deprecated public static interface InvocableMap.ParallelAwareAggregator<K,V,P,R> extends InvocableMap.EntryAggregator<K,V,R>
Deprecated.This interface was deprecated in Coherence 12.2.1 and might be removed in a future release. UseInvocableMap.StreamingAggregator
instead.A ParallelAwareAggregator is an advanced extension to EntryAggregator that is explicitly capable of being run in parallel, for example in a distributed environment.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
InvocableMap.ParallelAwareAggregator.PartialResultAggregator<P>
Deprecated.This interface was deprecated in Coherence 12.2.1 and might be removed in a future release.
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description R
aggregateResults(Collection<P> collResults)
Deprecated.Aggregate the results of the partial aggregations into a final result.InvocableMap.EntryAggregator<K,V,P>
getParallelAggregator()
Deprecated.Get an aggregator that can take the place of this aggregator in situations in which the InvocableMap can aggregate in parallel.-
Methods inherited from interface com.tangosol.util.InvocableMap.EntryAggregator
aggregate
-
-
-
-
Method Detail
-
getParallelAggregator
InvocableMap.EntryAggregator<K,V,P> getParallelAggregator()
Deprecated.Get an aggregator that can take the place of this aggregator in situations in which the InvocableMap can aggregate in parallel.If the returned aggregator is a
InvocableMap.ParallelAwareAggregator.PartialResultAggregator
, the partial results of the aggregation may be furtheraggregated
where optimal.- Returns:
- the aggregator that can be run in parallel
-
aggregateResults
R aggregateResults(Collection<P> collResults)
Deprecated.Aggregate the results of the partial aggregations into a final result.- Parameters:
collResults
- the partial aggregation results- Returns:
- the aggregation of the partial aggregation results
-
-