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 © 2020 Hazelcast, Inc.. All Rights Reserved.