Package | Description |
---|---|
com.hazelcast.client.impl.querycache.subscriber |
Contains Hazelcast Enterprise version client-side query cache
subscriber implementation classes.
|
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.subscriber.operation |
This package contains Enterprise specific operations for
QueryCache . |
Modifier and Type | Method and Description |
---|---|
void |
ClientQueryCacheEndToEndConstructor.createPublisherAccumulator(AccumulatorInfo info) |
Modifier and Type | Method and Description |
---|---|
void |
PostJoinMapOperation.setInfoList(List<AccumulatorInfo> infoList) |
Modifier and Type | Method and Description |
---|---|
AccumulatorInfo |
DefaultAccumulatorInfoSupplier.getAccumulatorInfoOrNull(String mapName,
String cacheId) |
AccumulatorInfo |
AccumulatorInfoSupplier.getAccumulatorInfoOrNull(String mapName,
String cacheId)
Returns
AccumulatorInfo for cache of maIMap p. |
AccumulatorInfo |
BasicAccumulator.getInfo() |
AccumulatorInfo |
Accumulator.getInfo()
Returns
AccumulatorInfo of this accumulator. |
static AccumulatorInfo |
AccumulatorInfo.toAccumulatorInfo(QueryCacheConfig config,
String mapName,
String cacheId,
Predicate predicate) |
static AccumulatorInfo |
AccumulatorInfo.toAccumulatorInfo(String mapName,
String cacheId,
Predicate predicate,
int batchSize,
int bufferSize,
long delaySeconds,
boolean includeValue,
boolean populate,
boolean coalesce) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,ConcurrentMap<String,AccumulatorInfo>> |
DefaultAccumulatorInfoSupplier.getAll() |
ConcurrentMap<String,ConcurrentMap<String,AccumulatorInfo>> |
AccumulatorInfoSupplier.getAll() |
Modifier and Type | Method and Description |
---|---|
Accumulator |
AccumulatorFactory.createAccumulator(AccumulatorInfo info) |
protected AccumulatorHandler<E> |
BasicAccumulator.createAccumulatorHandler(QueryCacheContext context,
AccumulatorInfo info) |
protected AccumulatorProcessor<Sequenced> |
BasicAccumulator.createAccumulatorProcessor(AccumulatorInfo info,
QueryCacheEventService eventService) |
void |
DefaultAccumulatorInfoSupplier.putIfAbsent(String mapName,
String cacheId,
AccumulatorInfo info) |
void |
AccumulatorInfoSupplier.putIfAbsent(String mapName,
String cacheId,
AccumulatorInfo info)
Adds a new
AccumulatorInfo for the query-cache of IMap . |
Constructor and Description |
---|
BasicAccumulator(QueryCacheContext context,
AccumulatorInfo info) |
Modifier and Type | Method and Description |
---|---|
AccumulatorInfo |
PartitionAccumulatorRegistry.getInfo() |
Modifier and Type | Method and Description |
---|---|
Accumulator |
PublisherAccumulatorFactory.createAccumulator(AccumulatorInfo info) |
void |
EventPublisherAccumulatorProcessor.setInfo(AccumulatorInfo info) |
Constructor and Description |
---|
EventPublisherAccumulatorProcessor(AccumulatorInfo info,
QueryCacheEventService eventService) |
PartitionAccumulatorRegistry(AccumulatorInfo info,
ConstructorFunction<Integer,Accumulator> accumulatorConstructor) |
Modifier and Type | Method and Description |
---|---|
Accumulator |
SubscriberAccumulatorFactory.createAccumulator(AccumulatorInfo info) |
protected AccumulatorHandler<QueryCacheEventData> |
SubscriberAccumulator.createAccumulatorHandler(QueryCacheContext context,
AccumulatorInfo info) |
void |
QueryCacheEndToEndConstructor.createPublisherAccumulator(AccumulatorInfo info)
Creates a new publisher-accumulator according to
AccumulatorInfo . |
void |
NodeQueryCacheEndToEndConstructor.createPublisherAccumulator(AccumulatorInfo info) |
void |
AbstractQueryCacheEndToEndConstructor.createSubscriberAccumulator(AccumulatorInfo info) |
void |
QueryCacheEndToEndConstructor.createSubscriberAccumulator(AccumulatorInfo info)
Creates a new
SubscriberAccumulator |
Constructor and Description |
---|
SubscriberAccumulator(QueryCacheContext context,
AccumulatorInfo info) |
SubscriberListener(QueryCacheContext context,
AccumulatorInfo info) |
Constructor and Description |
---|
PublisherCreateOperation(AccumulatorInfo info) |
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.