Package com.tangosol.util

Interface InvocableMap.ParallelAwareAggregator<K,V,P,R>

Type Parameters:
K - the type of the Map entry keys
V - the type of the Map entry values
P - the type of the intermediate result during the parallel stage
R - 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. Use InvocableMap.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.

  • Method Details

    • 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 further aggregated 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