Package | Description |
---|---|
com.hazelcast.client.impl.querycache |
Contains query cache internal implementations for client side.
|
com.hazelcast.client.impl.querycache.subscriber |
Contains Hazelcast Enterprise version client-side query cache
subscriber implementation classes.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.event | |
com.hazelcast.map.impl.querycache |
Contains query cache internal implementation classes.
|
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. |
Modifier and Type | Class and Description |
---|---|
class |
ClientQueryCacheContext
Client side implementation of
QueryCacheContext . |
Constructor and Description |
---|
ClientInvokerWrapper(QueryCacheContext context,
HazelcastClientInstanceImpl client) |
ClientSubscriberContext(QueryCacheContext context) |
Modifier and Type | Method and Description |
---|---|
QueryCacheContext |
MapServiceContext.getQueryCacheContext() |
Constructor and Description |
---|
QueryCacheEventPublisher(FilteringStrategy filteringStrategy,
QueryCacheContext queryCacheContext,
InternalSerializationService serializationService) |
Modifier and Type | Class and Description |
---|---|
class |
NodeQueryCacheContext
Node side implementation of
QueryCacheContext . |
Modifier and Type | Method and Description |
---|---|
protected AccumulatorHandler<E> |
BasicAccumulator.createAccumulatorHandler(QueryCacheContext context,
AccumulatorInfo info) |
Constructor and Description |
---|
AccumulatorScannerTask(QueryCacheContext context) |
BasicAccumulator(QueryCacheContext context,
AccumulatorInfo info) |
Modifier and Type | Method and Description |
---|---|
QueryCacheContext |
DefaultPublisherContext.getContext() |
QueryCacheContext |
PublisherContext.getContext()
Returns
QueryCacheContext on this node. |
Constructor and Description |
---|
DefaultPublisherContext(QueryCacheContext context,
NodeEngine nodeEngine,
IFunction<String,String> listenerRegistrator) |
MapListenerRegistry(QueryCacheContext context) |
MapPublisherRegistry(QueryCacheContext context) |
PublisherAccumulatorFactory(QueryCacheContext context) |
PublisherAccumulatorHandler(QueryCacheContext context,
AccumulatorProcessor<Sequenced> processor) |
PublisherRegistry(QueryCacheContext context,
String mapName) |
QueryCacheListenerRegistry(QueryCacheContext context,
String mapName) |
Modifier and Type | Field and Description |
---|---|
protected QueryCacheContext |
AbstractQueryCacheEndToEndConstructor.context |
Modifier and Type | Method and Description |
---|---|
QueryCacheContext |
QueryCacheRequest.getContext() |
protected QueryCacheContext |
SubscriberRegistry.getContext() |
protected QueryCacheContext |
SubscriberAccumulatorFactory.getContext() |
protected QueryCacheContext |
MapSubscriberRegistry.getContext() |
Modifier and Type | Method and Description |
---|---|
protected AccumulatorHandler<QueryCacheEventData> |
SubscriberAccumulator.createAccumulatorHandler(QueryCacheContext context,
AccumulatorInfo info) |
static void |
EventPublisherHelper.publishEventLost(QueryCacheContext context,
String mapName,
String cacheId,
int partitionId,
Extractors extractors) |
QueryCacheRequest |
QueryCacheRequest.withContext(QueryCacheContext context) |
Constructor and Description |
---|
AbstractSubscriberContext(QueryCacheContext context) |
MapSubscriberRegistry(QueryCacheContext context) |
NodeSubscriberContext(QueryCacheContext context) |
SubscriberAccumulator(QueryCacheContext context,
AccumulatorInfo info) |
SubscriberAccumulatorFactory(QueryCacheContext context) |
SubscriberListener(QueryCacheContext context,
AccumulatorInfo info) |
SubscriberRegistry(QueryCacheContext context,
String mapName) |
Modifier and Type | Method and Description |
---|---|
static Accumulator |
QueryCacheUtil.getAccumulatorOrNull(QueryCacheContext context,
String mapName,
String cacheId,
int partitionId)
Returns
Accumulator of a partition. |
static PartitionAccumulatorRegistry |
QueryCacheUtil.getAccumulatorRegistryOrNull(QueryCacheContext context,
String mapName,
String cacheId)
Returns
PartitionAccumulatorRegistry of a QueryCache . |
static Map<Integer,Accumulator> |
QueryCacheUtil.getAccumulators(QueryCacheContext context,
String mapName,
String cacheId)
Returns accumulators of a
QueryCache . |
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.