CustomAggregatingEnricher (Apache Brooklyn)

java.lang.Object
- brooklyn.basic.AbstractBrooklynObject
- - brooklyn.policy.basic.AbstractEntityAdjunct
  - - brooklyn.enricher.basic.AbstractEnricher
    - - brooklyn.enricher.basic.AbstractAggregatingEnricher<S,T>
      - brooklyn.enricher.CustomAggregatingEnricher<S,T>

Type Parameters:
T -

All Implemented Interfaces:

BrooklynObject, BrooklynObjectInternal, Rebindable, Configurable, Identifiable, SensorEventListener<S>, Enricher, EntityAdjunct

Deprecated.
since 0.7.0; use Enrichers.builder()
```
public class CustomAggregatingEnricher<S,T>
extends AbstractAggregatingEnricher<S,T>
implements SensorEventListener<S>
```
Subscribes to events from producers with a sensor of type T, aggregates them with the provided closure and emits the result on the target sensor V.

Nested Class Summary
- Nested classes/interfaces inherited from class brooklyn.policy.basic.AbstractEntityAdjunct
  AbstractEntityAdjunct.AdjunctTagSupport
- Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObject
  BrooklynObject.TagSupport
- Nested classes/interfaces inherited from interface brooklyn.entity.trait.Configurable
  Configurable.ConfigurationSupport
- Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObjectInternal
  BrooklynObjectInternal.ConfigurationSupportInternal

Field Summary
- Fields inherited from class brooklyn.enricher.basic.AbstractEnricher
  SUPPRESS_DUPLICATES
- Fields inherited from interface brooklyn.event.SensorEventListener
  NOOP

Constructor Summary

Constructors
Constructor and Description
`CustomAggregatingEnricher(AttributeSensor<? extends S> source, AttributeSensor<T> target, com.google.common.base.Function<java.util.Collection<S>,T> aggregator)` Deprecated.
`CustomAggregatingEnricher(AttributeSensor<? extends S> source, AttributeSensor<T> target, com.google.common.base.Function<java.util.Collection<S>,T> aggregator, S defaultValue)` Deprecated.
`CustomAggregatingEnricher(AttributeSensor<S> source, AttributeSensor<T> target, groovy.lang.Closure<?> aggregator)` Deprecated.
`CustomAggregatingEnricher(AttributeSensor<S> source, AttributeSensor<T> target, groovy.lang.Closure<?> aggregator, S defaultValueForUnreportedSensors)` Deprecated.
`CustomAggregatingEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<? extends S> source, AttributeSensor<T> target, groovy.lang.Closure<?> aggregator)` Deprecated.
`CustomAggregatingEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<? extends S> source, AttributeSensor<T> target, groovy.lang.Closure<?> aggregator, S defaultValueForUnreportedSensors)` Deprecated.
`CustomAggregatingEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<? extends S> source, AttributeSensor<T> target, com.google.common.base.Function<java.util.Collection<S>,T> aggregator)` Deprecated.
`CustomAggregatingEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<? extends S> source, AttributeSensor<T> target, com.google.common.base.Function<java.util.Collection<S>,T> aggregator, S defaultIniitalValueForUnreportedSensors)` Deprecated. The valid keys for the flags are: - producers: a collection of entities to be aggregated - allMembers: indicates that should track members of the entity that the aggregator is associated with, to aggregate across all those members.

Method Summary

Methods
Modifier and Type	Method and Description
`T`	`getAggregate()` Deprecated.
`static <N extends java.lang.Number> CustomAggregatingEnricher<N,java.lang.Double>`	`newAveragingEnricher(AttributeSensor<N> source, AttributeSensor<java.lang.Double> target)` Deprecated.
`static <N extends java.lang.Number> CustomAggregatingEnricher<N,java.lang.Double>`	`newAveragingEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<? extends N> source, AttributeSensor<java.lang.Double> target, N defaultValueForUnreportedSensors, java.lang.Double valueToReportIfNoSensors)` Deprecated. since 0.7.0; use `Enrichers.builder()`
`static <S,T> CustomAggregatingEnricher<S,T>`	`newEnricher(AttributeSensor<S> source, AttributeSensor<T> target, groovy.lang.Closure<?> aggregator)` Deprecated.
`static <S,T> CustomAggregatingEnricher<S,T>`	`newEnricher(AttributeSensor<S> source, AttributeSensor<T> target, groovy.lang.Closure<?> aggregator, S defaultVal)` Deprecated.
`static <S,T> CustomAggregatingEnricher<S,T>`	`newEnricher(AttributeSensor<S> source, AttributeSensor<T> target, com.google.common.base.Function<java.util.Collection<S>,T> aggregator)` Deprecated.
`static <S,T> CustomAggregatingEnricher<S,T>`	`newEnricher(AttributeSensor<S> source, AttributeSensor<T> target, com.google.common.base.Function<java.util.Collection<S>,T> aggregator, S defaultVal)` Deprecated.
`static <S,T> CustomAggregatingEnricher<S,T>`	`newEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<S> source, AttributeSensor<T> target, groovy.lang.Closure<?> aggregator)` Deprecated.
`static <S,T> CustomAggregatingEnricher<S,T>`	`newEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<S> source, AttributeSensor<T> target, groovy.lang.Closure<?> aggregator, S defaultVal)` Deprecated. since 0.7.0; use `Enrichers.builder()`
`static <S,T> CustomAggregatingEnricher<S,T>`	`newEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<S> source, AttributeSensor<T> target, com.google.common.base.Function<java.util.Collection<S>,T> aggregator)` Deprecated.
`static <S,T> CustomAggregatingEnricher<S,T>`	`newEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<S> source, AttributeSensor<T> target, com.google.common.base.Function<java.util.Collection<S>,T> aggregator, S defaultVal)` Deprecated. since 0.7.0; use `Enrichers.builder()`
`static <N extends java.lang.Number> CustomAggregatingEnricher<N,N>`	`newSummingEnricher(AttributeSensor<N> source, AttributeSensor<N> target)` Deprecated.
`static <N extends java.lang.Number,T extends java.lang.Number> CustomAggregatingEnricher<N,T>`	`newSummingEnricher(java.util.Map<java.lang.String,?> flags, AttributeSensor<N> source, AttributeSensor<T> target, N defaultValueForUnreportedSensors, T valueToReportIfNoSensors)` Deprecated. since 0.7.0; use `Enrichers.builder()`
`void`	`onUpdated()` Deprecated. Called whenever the values for the set of producers changes (e.g.

Methods inherited from class brooklyn.enricher.basic.AbstractAggregatingEnricher
addProducer, onEvent, removeProducer, setEntity

Methods inherited from class brooklyn.enricher.basic.AbstractEnricher
getEnricherType, getRebindSupport

Methods inherited from class brooklyn.policy.basic.AbstractEntityAdjunct
config, configure, destroy, getAllConfig, getConfig, getConfigMap, getDisplayName, getName, getUniqueTag, isDestroyed, isRunning, setConfig, setDisplayName, setName, tags, toString

Methods inherited from class brooklyn.basic.AbstractBrooklynObject
getCatalogItemId, getId, getManagementContext, getTagSupport, init, rebind, setCatalogItemId, setManagementContext

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface brooklyn.event.SensorEventListener
onEvent

Methods inherited from interface brooklyn.policy.Enricher
getAllConfig, getConfig, getId, getName, setConfig

Methods inherited from interface brooklyn.policy.EntityAdjunct
getUniqueTag, isDestroyed, isRunning

Methods inherited from interface brooklyn.basic.BrooklynObject
getCatalogItemId, getDisplayName, getTagSupport, tags

Methods inherited from interface brooklyn.entity.trait.Configurable
config

Methods inherited from interface brooklyn.basic.BrooklynObjectInternal
setCatalogItemId

Constructor Detail

CustomAggregatingEnricher
```
public CustomAggregatingEnricher(java.util.Map<java.lang.String,?> flags,
                         AttributeSensor<? extends S> source,
                         AttributeSensor<T> target,
                         com.google.common.base.Function<java.util.Collection<S>,T> aggregator,
                         S defaultIniitalValueForUnreportedSensors)
```
Deprecated.

The valid keys for the flags are: - producers: a collection of entities to be aggregated - allMembers: indicates that should track members of the entity that the aggregator is associated with, to aggregate across all those members. - filter: a Predicate or Closure, indicating which entities to include

Parameters:
flags -
source -
target -
aggregator - Aggregates a collection of values, to return a single value for the target sensor
defaultIniitalValueForUnreportedSensors - Default value to populate the collection given to aggregator, where sensors are null or not present initially, defaults to null (note however that subsequent null reports will put an explicit null)

CustomAggregatingEnricher

public CustomAggregatingEnricher(java.util.Map<java.lang.String,?> flags,
                         AttributeSensor<? extends S> source,
                         AttributeSensor<T> target,
                         com.google.common.base.Function<java.util.Collection<S>,T> aggregator)

Deprecated.

CustomAggregatingEnricher

public CustomAggregatingEnricher(AttributeSensor<? extends S> source,
                         AttributeSensor<T> target,
                         com.google.common.base.Function<java.util.Collection<S>,T> aggregator,
                         S defaultValue)

Deprecated.

CustomAggregatingEnricher

public CustomAggregatingEnricher(AttributeSensor<? extends S> source,
                         AttributeSensor<T> target,
                         com.google.common.base.Function<java.util.Collection<S>,T> aggregator)

Deprecated.

CustomAggregatingEnricher

public CustomAggregatingEnricher(java.util.Map<java.lang.String,?> flags,
                         AttributeSensor<? extends S> source,
                         AttributeSensor<T> target,
                         groovy.lang.Closure<?> aggregator,
                         S defaultValueForUnreportedSensors)

Deprecated.

Parameters:: flags -; source -; target -; aggregator - Should take a collection of values and return a single, aggregate value; defaultValueForUnreportedSensors -
See Also:: CustomAggregatingEnricher(Map, AttributeSensor, AttributeSensor, Function, Object)

CustomAggregatingEnricher

public CustomAggregatingEnricher(java.util.Map<java.lang.String,?> flags,
                         AttributeSensor<? extends S> source,
                         AttributeSensor<T> target,
                         groovy.lang.Closure<?> aggregator)

Deprecated.

CustomAggregatingEnricher

public CustomAggregatingEnricher(AttributeSensor<S> source,
                         AttributeSensor<T> target,
                         groovy.lang.Closure<?> aggregator,
                         S defaultValueForUnreportedSensors)

Deprecated.

CustomAggregatingEnricher

public CustomAggregatingEnricher(AttributeSensor<S> source,
                         AttributeSensor<T> target,
                         groovy.lang.Closure<?> aggregator)

Deprecated.

Method Detail

onUpdated
```
public void onUpdated()
```
Deprecated.

Description copied from class: AbstractAggregatingEnricher

Called whenever the values for the set of producers changes (e.g. on an event, or on a member added/removed). Defaults to no-op

getAggregate
```
public T getAggregate()
```
Deprecated.

newEnricher

public static <S,T> CustomAggregatingEnricher<S,T> newEnricher(java.util.Map<java.lang.String,?> flags,
                                               AttributeSensor<S> source,
                                               AttributeSensor<T> target,
                                               groovy.lang.Closure<?> aggregator,
                                               S defaultVal)

Deprecated. since 0.7.0; use Enrichers.builder()

Instead, consider calling:

 Enrichers.Builder builder = Enrichers.builder()
         .aggregating(source)
         .publishing(target)
         .computing(GroovyJavaMethods.<Collection<S>, T>functionFromClosure((Closure<T>)aggregator))
         .defaultValueForUnreportedSensors(defaultValueForUnreportedSensors);
 
 if (Boolean.TRUE.equals(allMembers)) builder.fromMembers();
 if (filter != null) builder.entityFilter(filter);
 if (hardCodedProducers != null) builder.fromHardcodedProducers(hardCodedProducers);
 
 addEnricher(builder.build());

newEnricher

public static <S,T> CustomAggregatingEnricher<S,T> newEnricher(java.util.Map<java.lang.String,?> flags,
                                               AttributeSensor<S> source,
                                               AttributeSensor<T> target,
                                               groovy.lang.Closure<?> aggregator)

Deprecated.

newEnricher

public static <S,T> CustomAggregatingEnricher<S,T> newEnricher(AttributeSensor<S> source,
                                               AttributeSensor<T> target,
                                               groovy.lang.Closure<?> aggregator,
                                               S defaultVal)

Deprecated.

newEnricher

public static <S,T> CustomAggregatingEnricher<S,T> newEnricher(AttributeSensor<S> source,
                                               AttributeSensor<T> target,
                                               groovy.lang.Closure<?> aggregator)

Deprecated.

newEnricher

public static <S,T> CustomAggregatingEnricher<S,T> newEnricher(java.util.Map<java.lang.String,?> flags,
                                               AttributeSensor<S> source,
                                               AttributeSensor<T> target,
                                               com.google.common.base.Function<java.util.Collection<S>,T> aggregator,
                                               S defaultVal)

Deprecated. since 0.7.0; use Enrichers.builder()

Instead, consider calling:

 Enrichers.Builder builder = Enrichers.builder()
         .aggregating(source)
         .publishing(target)
         .computing(aggregator)
         .defaultValueForUnreportedSensors(defaultVal);
 
 if (Boolean.TRUE.equals(allMembers)) builder.fromMembers();
 if (filter != null) builder.entityFilter(filter);
 if (hardCodedProducers != null) builder.fromHardcodedProducers(hardCodedProducers);
 
 addEnricher(builder.build());

newEnricher

public static <S,T> CustomAggregatingEnricher<S,T> newEnricher(java.util.Map<java.lang.String,?> flags,
                                               AttributeSensor<S> source,
                                               AttributeSensor<T> target,
                                               com.google.common.base.Function<java.util.Collection<S>,T> aggregator)

Deprecated.

newEnricher

public static <S,T> CustomAggregatingEnricher<S,T> newEnricher(AttributeSensor<S> source,
                                               AttributeSensor<T> target,
                                               com.google.common.base.Function<java.util.Collection<S>,T> aggregator,
                                               S defaultVal)

Deprecated.

newEnricher

public static <S,T> CustomAggregatingEnricher<S,T> newEnricher(AttributeSensor<S> source,
                                               AttributeSensor<T> target,
                                               com.google.common.base.Function<java.util.Collection<S>,T> aggregator)

Deprecated.

newSummingEnricher

public static <N extends java.lang.Number,T extends java.lang.Number> CustomAggregatingEnricher<N,T> newSummingEnricher(java.util.Map<java.lang.String,?> flags,
                                                                                                        AttributeSensor<N> source,
                                                                                                        AttributeSensor<T> target,
                                                                                                        N defaultValueForUnreportedSensors,
                                                                                                        T valueToReportIfNoSensors)

Deprecated. since 0.7.0; use Enrichers.builder()

creates an enricher which sums over all children/members, defaulting to excluding sensors which have not published anything (or published null), and null if there are no sensors; this behaviour can be customised, both default value for sensors, and what to report if no sensors Instead, consider calling:

 Enrichers.Builder builder = Enrichers.builder()
         .aggregating(source)
         .publishing(target)
         .computingSum()
         .defaultValueForUnreportedSensors(defaultValueForUnreportedSensors)
         .valueToReportIfNoSensors(valueToReportIfNoSensors);
 
 if (Boolean.TRUE.equals(allMembers)) builder.fromMembers();
 if (filter != null) builder.entityFilter(filter);
 if (hardCodedProducers != null) builder.fromHardcodedProducers(hardCodedProducers);
 
 addEnricher(builder.build());

newSummingEnricher

public static <N extends java.lang.Number> CustomAggregatingEnricher<N,N> newSummingEnricher(AttributeSensor<N> source,
                                                                             AttributeSensor<N> target)

Deprecated.

See Also:: #newSummingEnricher(Map, AttributeSensor, AttributeSensor, Number, Number)}

newAveragingEnricher

public static <N extends java.lang.Number> CustomAggregatingEnricher<N,java.lang.Double> newAveragingEnricher(java.util.Map<java.lang.String,?> flags,
                                                                                              AttributeSensor<? extends N> source,
                                                                                              AttributeSensor<java.lang.Double> target,
                                                                                              N defaultValueForUnreportedSensors,
                                                                                              java.lang.Double valueToReportIfNoSensors)

Deprecated. since 0.7.0; use Enrichers.builder()

creates an enricher which averages over all children/members, defaulting to excluding sensors which have not published anything (or published null), and null if there are no sensors; this behaviour can be customised, both default value for sensors, and what to report if no sensors Instead, consider calling:

 Enrichers.Builder builder = Enrichers.builder()
         .aggregating(source)
         .publishing(target)
         .computingAverage()
         .defaultValueForUnreportedSensors(defaultValueForUnreportedSensors)
         .valueToReportIfNoSensors(valueToReportIfNoSensors);
 
 if (Boolean.TRUE.equals(allMembers)) builder.fromMembers();
 if (filter != null) builder.entityFilter(filter);
 if (hardCodedProducers != null) builder.fromHardcodedProducers(hardCodedProducers);
 
 addEnricher(builder.build());

newAveragingEnricher

public static <N extends java.lang.Number> CustomAggregatingEnricher<N,java.lang.Double> newAveragingEnricher(AttributeSensor<N> source,
                                                                                              AttributeSensor<java.lang.Double> target)

Deprecated.

See Also:: newAveragingEnricher(Map, AttributeSensor, AttributeSensor, Number, Double)

Class CustomAggregatingEnricher<S,T>

Nested Class Summary

Nested classes/interfaces inherited from class brooklyn.policy.basic.AbstractEntityAdjunct

Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObject

Nested classes/interfaces inherited from interface brooklyn.entity.trait.Configurable

Nested classes/interfaces inherited from interface brooklyn.basic.BrooklynObjectInternal

Field Summary

Fields inherited from class brooklyn.enricher.basic.AbstractEnricher

Fields inherited from interface brooklyn.event.SensorEventListener

Constructor Summary

Method Summary

Methods inherited from class brooklyn.enricher.basic.AbstractAggregatingEnricher

Methods inherited from class brooklyn.enricher.basic.AbstractEnricher

Methods inherited from class brooklyn.policy.basic.AbstractEntityAdjunct

Methods inherited from class brooklyn.basic.AbstractBrooklynObject

Methods inherited from class java.lang.Object

Methods inherited from interface brooklyn.event.SensorEventListener

Methods inherited from interface brooklyn.policy.Enricher

Methods inherited from interface brooklyn.policy.EntityAdjunct

Methods inherited from interface brooklyn.basic.BrooklynObject

Methods inherited from interface brooklyn.entity.trait.Configurable

Methods inherited from interface brooklyn.basic.BrooklynObjectInternal

Constructor Detail

CustomAggregatingEnricher

CustomAggregatingEnricher

CustomAggregatingEnricher

CustomAggregatingEnricher

CustomAggregatingEnricher

CustomAggregatingEnricher

CustomAggregatingEnricher

CustomAggregatingEnricher

Method Detail

onUpdated

getAggregate

newEnricher

newEnricher

newEnricher

newEnricher

newEnricher

newEnricher

newEnricher

newEnricher

newSummingEnricher

newSummingEnricher

newAveragingEnricher

newAveragingEnricher