| Package | Description |
|---|---|
| com.hazelcast.map.impl.operation |
Package for map operations.
|
| 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. |
| com.hazelcast.map.impl.querycache.utils |
Contains utility classes for
QueryCache implementation. |
| Constructor and Description |
|---|
AccumulatorConsumerOperation(Queue<Accumulator> accumulators,
int maxProcessableAccumulatorCount) |
| Modifier and Type | Class and Description |
|---|---|
class |
BasicAccumulator<E extends Sequenced>
This class implements basic functionality of an
Accumulator. |
| Modifier and Type | Method and Description |
|---|---|
Accumulator |
AccumulatorFactory.createAccumulator(AccumulatorInfo info) |
| Modifier and Type | Method and Description |
|---|---|
Accumulator |
PublisherAccumulatorFactory.createAccumulator(AccumulatorInfo info) |
Accumulator |
PartitionAccumulatorRegistry.getOrCreate(Integer partitionId) |
Accumulator |
PartitionAccumulatorRegistry.getOrNull(Integer partitionId) |
Accumulator |
PartitionAccumulatorRegistry.remove(Integer id) |
| Modifier and Type | Method and Description |
|---|---|
Map<Integer,Accumulator> |
PartitionAccumulatorRegistry.getAll() |
| Constructor and Description |
|---|
PartitionAccumulatorRegistry(AccumulatorInfo info,
ConstructorFunction<Integer,Accumulator> accumulatorConstructor) |
| Modifier and Type | Class and Description |
|---|---|
class |
SubscriberAccumulator
If all incoming events are in the correct sequence order, this accumulator applies those events to
QueryCache. |
| Modifier and Type | Method and Description |
|---|---|
Accumulator |
SubscriberAccumulatorFactory.createAccumulator(AccumulatorInfo info) |
Accumulator |
SubscriberRegistry.getOrCreate(String cacheId) |
Accumulator |
SubscriberRegistry.getOrNull(String cacheId) |
Accumulator |
SubscriberRegistry.remove(String cacheId) |
| Modifier and Type | Method and Description |
|---|---|
Map<String,Accumulator> |
SubscriberRegistry.getAll() |
| Modifier and Type | Method and Description |
|---|---|
static Accumulator |
QueryCacheUtil.getAccumulatorOrNull(QueryCacheContext context,
String mapName,
String cacheId,
int partitionId)
Returns
Accumulator of a partition. |
| Modifier and Type | Method and Description |
|---|---|
static Map<Integer,Accumulator> |
QueryCacheUtil.getAccumulators(QueryCacheContext context,
String mapName,
String cacheId)
Returns accumulators of a
QueryCache. |
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.