| Package | Description | 
|---|---|
| com.hazelcast.map.impl.querycache.accumulator | 
 Contains  
Accumulator
 specific classes. | 
| com.hazelcast.map.impl.querycache.event | 
 This package contains classes for query cache events. 
 | 
| com.hazelcast.map.impl.querycache.publisher | 
 This package contains classes which are used for  
QueryCache
 event publishing side. | 
| com.hazelcast.map.impl.querycache.subscriber | 
 This package contains classes which are used for  
QueryCache
 event subscription side. | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
Accumulator<E extends Sequenced>
Accumulator for events which have a sequence number. 
 | 
class  | 
BasicAccumulator<E extends Sequenced>
This class implements basic functionality of an  
Accumulator. | 
interface  | 
CyclicBuffer<E extends Sequenced>
A cyclic buffer to store  
Sequenced events. | 
class  | 
DefaultCyclicBuffer<E extends Sequenced>
Default implementation of  
CyclicBuffer interface. | 
| Modifier and Type | Method and Description | 
|---|---|
protected AccumulatorProcessor<Sequenced> | 
BasicAccumulator.createAccumulatorProcessor(AccumulatorInfo info,
                          QueryCacheEventService eventService)  | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
QueryCacheEventData
Event data contract which is sent to subscriber side. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
BatchEventData
Holder for a collection of  
QueryCacheEventData. | 
class  | 
DefaultQueryCacheEventData
Default implementation of  
QueryCacheEventData which is sent to subscriber. | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
PublisherAccumulatorHandler.handle(Sequenced eventData,
      boolean lastElement)  | 
void | 
EventPublisherAccumulatorProcessor.process(Sequenced sequenced)  | 
| Constructor and Description | 
|---|
PublisherAccumulatorHandler(QueryCacheContext context,
                           AccumulatorProcessor<Sequenced> processor)  | 
| Modifier and Type | Method and Description | 
|---|---|
protected boolean | 
SubscriberAccumulator.isNextEvent(Sequenced event)  | 
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.