| 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. |
| Modifier and Type | Field and Description |
|---|---|
protected AccumulatorHandler<E> |
BasicAccumulator.handler |
| 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. |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.