Class Hierarchy
- java.lang.Object
- org.opennms.core.ipc.sink.aggregation.AggregatingMessageProducer<S,T> (implements org.opennms.core.ipc.sink.api.MessageDispatcher<S>)
- org.opennms.core.ipc.sink.aggregation.AggregatingSinkMessageProducer<S,T> (implements org.opennms.core.ipc.sink.api.SyncDispatcher<S>)
- org.opennms.core.ipc.sink.aggregation.Aggregator<S,T> (implements java.lang.AutoCloseable, java.lang.Runnable)
- org.opennms.core.ipc.sink.aggregation.SinkAggregator<S,T>
- org.opennms.core.ipc.sink.aggregation.Aggregator.Bucket
- org.opennms.core.ipc.sink.aggregation.ArrayListAggregationPolicy<S> (implements org.opennms.core.ipc.sink.api.AggregationPolicy<S,T,U>)
- org.opennms.core.ipc.sink.aggregation.IdentityAggregationPolicy<T> (implements org.opennms.core.ipc.sink.api.AggregationPolicy<S,T,U>)
- org.opennms.core.ipc.sink.aggregation.MappingAggregationPolicy<S,T> (implements org.opennms.core.ipc.sink.api.AggregationPolicy<S,T,U>)
- org.opennms.core.ipc.sink.aggregation.AggregatingMessageProducer<S,T> (implements org.opennms.core.ipc.sink.api.MessageDispatcher<S>)