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