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.

This interface was deprecated in Coherence 12.2.1 and might be removed in a future release. Use InvocableMap.StreamingAggregator instead.

@Deprecated
public static interface InvocableMap.ParallelAwareAggregator<K,V,P,R>
extends InvocableMap.EntryAggregator<K,V,R>

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 and 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. Use InvocableMap.StreamingAggregator instead.

Method Summary

Modifier and Type	Method and 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 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