- java.lang.Object
-
- org.opennms.core.ipc.sink.aggregation.Aggregator<S,T>
-
- org.opennms.core.ipc.sink.aggregation.SinkAggregator<S,T>
-
- Type Parameters:
S
- individual messageT
- aggregated message (i.e. bucket)
- All Implemented Interfaces:
AutoCloseable
,Runnable
public class SinkAggregator<S extends Message,T extends Message> extends Aggregator<S,T>
This is a specific aggregator where the messsages implement theMessage
marker interface.- Author:
- jwhite
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.opennms.core.ipc.sink.aggregation.Aggregator
Aggregator.Bucket
-
-
Field Summary
-
Fields inherited from class org.opennms.core.ipc.sink.aggregation.Aggregator
DEFAULT_NUM_STRIPE_LOCKS, NUM_STRIPE_LOCKS_SYS_PROP
-
-
Constructor Summary
Constructors Constructor Description SinkAggregator(SinkModule<S,T> module, AggregatingSinkMessageProducer<S,T> messageProducer)
-
-
-
Constructor Detail
-
SinkAggregator
public SinkAggregator(SinkModule<S,T> module, AggregatingSinkMessageProducer<S,T> messageProducer)
-
-