Package | Description |
---|---|
com.hazelcast.map.impl.querycache.accumulator |
Contains
Accumulator
specific classes. |
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 | Field and Description |
---|---|
protected AccumulatorHandler<E> |
BasicAccumulator.handler |
Modifier and Type | Method and Description |
---|---|
protected AccumulatorHandler<E> |
BasicAccumulator.createAccumulatorHandler(QueryCacheContext context,
AccumulatorInfo info) |
Modifier and Type | Method and Description |
---|---|
int |
BasicAccumulator.poll(AccumulatorHandler<E> handler,
int maxItems) |
int |
Accumulator.poll(AccumulatorHandler<E> handler,
int maxItems)
Reads this accumulator if it contains at least
maxItems , otherwise
do not read anything. |
int |
BasicAccumulator.poll(AccumulatorHandler<E> handler,
long delay,
TimeUnit unit) |
int |
Accumulator.poll(AccumulatorHandler<E> handler,
long delay,
TimeUnit unit)
Reads all expired items to the supplied handler.
|
Modifier and Type | Class and Description |
---|---|
class |
PublisherAccumulatorHandler
Handler for processing of event data in an
Accumulator . |
Modifier and Type | Method and Description |
---|---|
protected AccumulatorHandler<QueryCacheEventData> |
SubscriberAccumulator.createAccumulatorHandler(QueryCacheContext context,
AccumulatorInfo info) |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.