Package com.inductiveautomation.ignition.common.util

Class OperationAggregator<T,K,R>

java.lang.Object

com.inductiveautomation.ignition.common.util.OperationAggregator<T,K,R>

All Implemented Interfaces:

Iterable<AggregationSet<T,K,R>>

public class OperationAggregator<T,K,R>
extends Object
implements Iterable<AggregationSet<T,K,R>>

The OperationAggregator takes a set of objects, splits them up based on keys determined by a KeyProvider, and then aggregates the results back together in the correct order, after some execution has occured.
Parameters: T - Request type K - Key type R - Result type
Usage:

1. Create new aggregator with correct types.
2. Call aggregator.put() with the input list, and a (usually anonymous) implementation of KeyProvider that returns the key for the given input.
3. Iterate through the AggregationSet<T,K,R\> now contained in the aggregator, do something.
4. Return aggregator.getResults()

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	OperationAggregator.AggregationEntry
static interface	OperationAggregator.InputValidator<T,R>	The InputValidator provides a way to validate input values before they get to execution.
static interface	OperationAggregator.KeyProvider<T,K>
protected class	OperationAggregator.ValueEntry

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<K,AggregationSet<T,K,R>>	breakup

Constructor Summary

Constructors

Constructor	Description
OperationAggregator()

Method Summary

Modifier and Type	Method	Description
Set<K>	getKeys()
List<R>	getResults()
Iterator<AggregationSet<T,K,R>>	iterator()
void	put(List<T> values, OperationAggregator.KeyProvider<T,K> provider)
void	put(List<T> values, OperationAggregator.KeyProvider<T,K> provider, OperationAggregator.InputValidator<T,R> validator)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

breakup

protected Map<K,AggregationSet<T,K,R>> breakup

Constructor Details

OperationAggregator

public OperationAggregator()

Method Details

put

public void put(List<T> values,
 OperationAggregator.KeyProvider<T,K> provider)

put

public void put(List<T> values,
 OperationAggregator.KeyProvider<T,K> provider,
 OperationAggregator.InputValidator<T,R> validator)

getResults

public List<R> getResults()

getKeys

public Set<K> getKeys()

Returns:

The Set of keys that have been provided to this OperationAggregator.

iterator

public Iterator<AggregationSet<T,K,R>> iterator()

Specified by:

iterator in interface Iterable<T>