S
- individual messageT
- aggregated message (i.e. bucket)public class SinkAggregator<S extends Message,T extends Message> extends Aggregator<S,T>
Message
marker interface.Aggregator.Bucket
DEFAULT_NUM_STRIPE_LOCKS, NUM_STRIPE_LOCKS_SYS_PROP
Constructor and Description |
---|
SinkAggregator(SinkModule<S,T> module,
AggregatingSinkMessageProducer<S,T> messageProducer) |
public SinkAggregator(SinkModule<S,T> module, AggregatingSinkMessageProducer<S,T> messageProducer)
Copyright © 2017. All rights reserved.