| Package | Description |
|---|---|
| com.hazelcast.aggregation.impl | |
| com.hazelcast.cache |
This package contains the public API extension for Hazelcast JCache,
the Hazelcast implementation of the JSR-107 commonly referred to as JCache.
|
| com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
| com.hazelcast.cache.impl.event |
Event classes to define listenters for JCache other than EntryListener
|
| com.hazelcast.cache.impl.journal | |
| com.hazelcast.cache.impl.merge.entry |
This package contains merge entry internal interfaces and functionality for Hazelcast cache.
|
| com.hazelcast.cache.impl.operation |
Hazelcast JSR-107 aka JCache implementation
|
| com.hazelcast.cache.impl.record |
Hazelcast JSR-107 aka JCache implementation
Internal record store
|
| com.hazelcast.cache.impl.tenantcontrol | |
| com.hazelcast.cardinality.impl | |
| com.hazelcast.cardinality.impl.hyperloglog |
This package contains spec for the HyperLogLog data-structure.
|
| com.hazelcast.cardinality.impl.hyperloglog.impl |
This package contains implementations of
HyperLogLog. |
| com.hazelcast.cardinality.impl.operations |
This package contains the operations on the
CardinalityEstimator. |
| com.hazelcast.client.config |
Contains classes related to config for com.hazelcast.client
|
| com.hazelcast.client.impl.operations |
Contains client operations
|
| com.hazelcast.client.impl.protocol.task.cache |
Client protocol tasks implementations for JCache
|
| com.hazelcast.client.impl.protocol.task.dynamicconfig | |
| com.hazelcast.client.impl.protocol.task.map |
Client protocol tasks implementations for map
|
| com.hazelcast.cluster.impl | |
| com.hazelcast.collection.impl.collection | |
| com.hazelcast.collection.impl.collection.operations | |
| com.hazelcast.collection.impl.list |
This package contains IList functionality for Hazelcast.
|
| com.hazelcast.collection.impl.list.operations | |
| com.hazelcast.collection.impl.queue | |
| com.hazelcast.collection.impl.queue.operations |
This package contains the IQueue operations
|
| com.hazelcast.collection.impl.set |
This package contains ISet functionality for Hazelcast.
|
| com.hazelcast.collection.impl.set.operations | |
| com.hazelcast.collection.impl.txncollection | |
| com.hazelcast.collection.impl.txncollection.operations | |
| com.hazelcast.collection.impl.txnqueue | |
| com.hazelcast.collection.impl.txnqueue.operations | |
| com.hazelcast.concurrent.atomiclong.operations |
This package contains the operations on the IAtomicLong.
|
| com.hazelcast.concurrent.atomicreference.operations |
This package contains the operations on the IAtomicReference.
|
| com.hazelcast.concurrent.countdownlatch |
This package contains ICountDownLatch functionality for Hazelcast.
The ICountDownLatch is the distributed version of the CountDownLatch. |
| com.hazelcast.concurrent.countdownlatch.operations |
This package contains the operations on the ICountDownLatch.
|
| com.hazelcast.concurrent.lock | |
| com.hazelcast.concurrent.lock.operations |
This package contains the operations on the ILock.
|
| com.hazelcast.concurrent.semaphore |
This package contains ISemaphore functionality for Hazelcast.
The ISemaphore is the distributed version of the Semaphore. |
| com.hazelcast.concurrent.semaphore.operations |
This package contains the operations on the ISemaphore.
|
| com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
| com.hazelcast.cp.internal |
Contains implementation of the CP subsystem
|
| com.hazelcast.cp.internal.datastructures.atomiclong |
Contains service classes for the Raft-based
IAtomicLong implementation |
| com.hazelcast.cp.internal.datastructures.atomiclong.operation |
Contains operations for the Raft-based
IAtomicLong implementation |
| com.hazelcast.cp.internal.datastructures.atomicref |
Contains service classes for the Raft-based
IAtomicReference implementation |
| com.hazelcast.cp.internal.datastructures.atomicref.operation |
Contains operations for the Raft-based
IAtomicReference implementation |
| com.hazelcast.cp.internal.datastructures.countdownlatch |
Contains service classes for the Raft-based
ICountDownLatch implementation |
| com.hazelcast.cp.internal.datastructures.countdownlatch.operation |
Contains operations for the Raft-based
ICountDownLatch implementation |
| com.hazelcast.cp.internal.datastructures.lock |
Contains service classes for the Raft-based
ILock
and FencedLock implementation |
| com.hazelcast.cp.internal.datastructures.lock.operation |
Contains operations for the Raft-based
ILock implementation |
| com.hazelcast.cp.internal.datastructures.semaphore |
Contains service classes for the Raft-based
ISemaphore implementation |
| com.hazelcast.cp.internal.datastructures.semaphore.operation |
Contains operations for the Raft-based
ISemaphore implementation |
| com.hazelcast.cp.internal.datastructures.spi.blocking |
Contains the interfaces and abstractions that are implemented / extended
by blocking Raft services, such as Lock, Semaphore, and CountDownLatch
|
| com.hazelcast.cp.internal.datastructures.spi.blocking.operation |
Contains the operations that are used by the
AbstractBlockingService abstraction |
| com.hazelcast.cp.internal.datastructures.spi.operation |
Contains the operations that is used for managing proxies
for the Raft-based data structure implementations
|
| com.hazelcast.cp.internal.operation |
Contains operations for the Raft Invocation SPI
|
| com.hazelcast.cp.internal.operation.integration |
Contains Hazelcast operations that carry out Raft RPCs
|
| com.hazelcast.cp.internal.raft.command |
Contains the
RaftGroupCmd
abstraction and its default impls |
| com.hazelcast.cp.internal.raft.impl.command |
Contains
RaftGroupCmd
implementations that are used by the core Raft algorithm implementation |
| com.hazelcast.cp.internal.raft.impl.dto |
Contains structs that are used in Raft RPCs
|
| com.hazelcast.cp.internal.raft.impl.log |
Contains the log abstraction which is maintained by the Raft algorithm
|
| com.hazelcast.cp.internal.raftop |
Contains operations that are used in Hazelcast's Raft implementation
|
| com.hazelcast.cp.internal.raftop.metadata |
Contains operations that are used in the Metadata CP group
|
| com.hazelcast.cp.internal.raftop.snapshot |
Contains operations that are used by Hazelcast to implement
Raft's snapshotting mechanism
|
| com.hazelcast.cp.internal.session |
Contains service classes
for the Raft-based
ISemaphore implementation |
| com.hazelcast.cp.internal.session.operation |
Contains operations that are internally used by the CP session API
|
| com.hazelcast.crdt |
This package contains CRDT (conflict-free replicated data type)
implementations based on the Hazelcast infrastructure.
|
| com.hazelcast.crdt.pncounter |
This package contains the PN (Positive-Negative) CRDT counter
implementation.
|
| com.hazelcast.crdt.pncounter.operations |
Contains the operations for the
PNCounter member-side
implementation. |
| com.hazelcast.durableexecutor.impl.operations |
This package contains operations for the DurableExecutorService.
|
| com.hazelcast.executor.impl |
This package contains IExecutorService functionality for Hazelcast.
The IExecutorService extends the ExecutorService and provides all kinds
of additional methods related to distributed systems. |
| com.hazelcast.executor.impl.operations |
This package contains operations for the IExecutorService.
|
| com.hazelcast.instance |
This package contains Hazelcast Instance functionality.
|
| com.hazelcast.internal.ascii.memcache |
This package contains MemoryCache functionality for Hazelcast.
|
| com.hazelcast.internal.ascii.rest |
This package contains Reset functionality for Hazelcast.
|
| com.hazelcast.internal.cluster |
Contains the internals for cluster management like discovery, joining etc.
|
| com.hazelcast.internal.cluster.impl |
This package contains the implementation of the cluster functionality.
|
| com.hazelcast.internal.cluster.impl.operations |
This package contains operations for the com.hazelcast.cluster.impl package.
|
| com.hazelcast.internal.dynamicconfig |
Classes related to Dynamic Configuration.
|
| com.hazelcast.internal.dynamicconfig.search |
Classes related to Config Search.
|
| com.hazelcast.internal.journal |
This package contains supporting classes for data structure specific event journals.
|
| com.hazelcast.internal.management.dto |
These contain the DTO object to exchange information with the management center.
|
| com.hazelcast.internal.management.operation |
Contains operations that are called from Management Center.
|
| com.hazelcast.internal.management.request |
Contains requests that made from Management Center.
|
| com.hazelcast.internal.nearcache.impl.invalidation |
Invalidations for Near Cache.
|
| com.hazelcast.internal.partition |
Contains the internals for partition assignment/management, migration, replication etc.
|
| com.hazelcast.internal.partition.operation |
Contains the operations for partition package.
|
| com.hazelcast.internal.serialization.impl | |
| com.hazelcast.internal.usercodedeployment.impl | |
| com.hazelcast.internal.usercodedeployment.impl.operation | |
| com.hazelcast.map.eviction |
This package contains eviction specific classes.
|
| com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
| com.hazelcast.map.impl.iterator | |
| com.hazelcast.map.impl.journal | |
| com.hazelcast.map.impl.nearcache.invalidation | |
| com.hazelcast.map.impl.operation |
Package for map operations.
|
| com.hazelcast.map.impl.query | |
| com.hazelcast.map.impl.querycache.subscriber.operation |
This package contains Enterprise specific operations for
QueryCache. |
| com.hazelcast.map.impl.record |
Contains record specific classes.
|
| com.hazelcast.map.impl.tx |
Contains implementation classes for
TransactionalMap |
| com.hazelcast.map.impl.wan |
Contains wan replication event classes
|
| com.hazelcast.map.merge |
Contains out-of-the-box merge policies for
IMap. |
| com.hazelcast.mapreduce.aggregation.impl |
This package contains a set of predefined aggregation implementations
|
| com.hazelcast.mapreduce.impl |
This package contains the default implementation for the map reduce framework
internals.
|
| com.hazelcast.mapreduce.impl.notification |
This package contains all remote node notifications
|
| com.hazelcast.mapreduce.impl.operation |
This package contains all remote operations that are needed to control work on
supervising or worker nodes.
|
| com.hazelcast.multimap.impl |
Contains classes for Hazelcast MultiMap module.
|
| com.hazelcast.multimap.impl.operations |
Contains operations for Hazelcast MultiMap module.
|
| com.hazelcast.multimap.impl.txn |
This package contains the Transaction behavior for the Multimap.
|
| com.hazelcast.nio |
This package contains classes related to New IO
|
| com.hazelcast.nio.serialization |
Contains interfaces/classes related to serialization;
such as serializer interfaces, input/output streams.
|
| com.hazelcast.nio.serialization.impl | |
| com.hazelcast.projection.impl | |
| com.hazelcast.query |
Contains interfaces/classes related to Hazelcast query and indexing support.
|
| com.hazelcast.query.impl |
Contains the implementation classes of the query functionality.
|
| com.hazelcast.query.impl.predicates | |
| com.hazelcast.replicatedmap.impl.operation |
This package contains replicated map operations which are executed on remote nodes
|
| com.hazelcast.replicatedmap.impl.record |
This package contains the implementation of the backing data storage for the replicated map implementation
|
| com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
| com.hazelcast.ringbuffer.impl.operations | |
| com.hazelcast.scheduledexecutor |
This package contains ScheduledExecutorService functionality for Hazelcast.
|
| com.hazelcast.scheduledexecutor.impl | |
| com.hazelcast.scheduledexecutor.impl.operations | |
| com.hazelcast.spi |
Provides interfaces/classes for the Hazelcast SPI for building distributed data structures and services.
|
| com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
| com.hazelcast.spi.impl.eventservice.impl |
Contains the code for the
InternalEventService implementation. |
| com.hazelcast.spi.impl.eventservice.impl.operations |
Contains the operations for the
EventServiceImpl. |
| com.hazelcast.spi.impl.merge |
This package contains split-brain related classes.
|
| com.hazelcast.spi.impl.operationservice.impl.operations |
Contains the Operations being used by the
OperationServiceImpl. |
| com.hazelcast.spi.impl.operationservice.impl.responses |
Contains the different responses that can be send as a consequence of an Operation invocation.
|
| com.hazelcast.spi.impl.proxyservice.impl.operations |
Contains the operations for the
ProxyServiceImpl. |
| com.hazelcast.spi.merge |
This package contains interfaces and classes of the split-brain merging SPI.
|
| com.hazelcast.topic.impl |
This package contains ITopic functionality for Hazelcast.
With the ITopic it is possible to create publish subscribe solutions similar to JMS Topics. |
| com.hazelcast.topic.impl.reliable | |
| com.hazelcast.transaction.impl |
Provides implementation for Hazelcast transaction support.
|
| com.hazelcast.transaction.impl.operations | |
| com.hazelcast.transaction.impl.xa |
Provides implementation for Hazelcast XA transaction support.
|
| com.hazelcast.transaction.impl.xa.operations | |
| com.hazelcast.version |
This package contains classes to support the versioning API.
|
| com.hazelcast.wan |
This package contains the WAN replication API
|
| Modifier and Type | Class and Description |
|---|---|
class |
BigDecimalAverageAggregator<I> |
class |
BigDecimalSumAggregator<I> |
class |
BigIntegerAverageAggregator<I> |
class |
BigIntegerSumAggregator<I> |
class |
CanonicalizingHashSet<E>
A read-only hash set that canonicalizes its mixed-type numeric elements for
lookup operations while still preserving the original element values.
|
class |
CountAggregator<I> |
class |
DistinctValuesAggregator<I,R> |
class |
DoubleAverageAggregator<I> |
class |
DoubleSumAggregator<I> |
class |
FixedSumAggregator<I> |
class |
FloatingPointSumAggregator<I> |
class |
IntegerAverageAggregator<I> |
class |
IntegerSumAggregator<I> |
class |
LongAverageAggregator<I> |
class |
LongSumAggregator<I> |
class |
MaxAggregator<I,R extends Comparable> |
class |
MaxByAggregator<I> |
class |
MinAggregator<I,R extends Comparable> |
class |
MinByAggregator<I> |
class |
NumberAverageAggregator<I> |
| Modifier and Type | Class and Description |
|---|---|
class |
HazelcastExpiryPolicy
Hazelcast provides overloads of the typical cache operations with a custom
ExpiryPolicy parameter.This class provides a custom implementation of an ExpiryPolicy to
react on all three types of policies:
Create
Access
Update
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CacheEventData
Internal event data wrapper used during publishing and dispatching events.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheClearResponse
This class is a simple object wrapper to be used by
CacheClearOperation. |
class |
CacheEntryIterationResult
Response data object returned by
CacheEntryIteratorOperation. |
class |
CacheEventDataImpl
Implementation of
CacheEventData. |
class |
CacheEventListenerAdaptor<K,V>
This implementation of
CacheEventListener uses the adapter pattern for wrapping all cache event listener
types into a single listener. |
class |
CacheEventSet
Internal Set wrapper of
CacheEventData items used during publishing and dispatching events. |
class |
CacheKeyIterationResult
Response data object returned by
CacheKeyIteratorOperation. |
class |
CachePartitionEventData |
class |
PreJoinCacheConfig<K,V>
This subclass of
CacheConfig is used to communicate cache configurations in pre-join cache operations when cluster
version is at least 3.9. |
| Modifier and Type | Class and Description |
|---|---|
class |
CachePartitionLostEventFilter
Used to filter partition lost listener events
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheEventJournalReadOperation<K,V,T>
Reads from the cache event journal in batches.
|
class |
CacheEventJournalReadResultSetImpl<K,V,T> |
class |
CacheEventJournalSubscribeOperation
Performs the initial subscription to the cache event journal.
|
class |
DeserializingEventJournalCacheEvent<K,V> |
class |
InternalEventJournalCacheEvent
The event journal item for map events.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DefaultCacheEntryView
Default heap based implementation of
CacheEntryView. |
| Modifier and Type | Class and Description |
|---|---|
class |
AddCacheConfigOperation |
class |
CacheBackupEntryProcessorOperation
Operation of the Cache Backup Entry Processor.
|
class |
CacheClearBackupOperation
Backup operation of
CacheClearOperation. |
class |
CacheClearExpiredOperation |
class |
CacheClearOperation
Cache Clear will clear all internal cache data without sending any event
|
class |
CacheClearOperationFactory
OperationFactory implementation for Clear Operations. |
class |
CacheContainsKeyOperation
Cache contains key operation, determines if the cache contains an entry for the specified key.
|
class |
CacheCreateConfigOperation
Deprecated.
as of 3.10 replaced by
AddCacheConfigOperation, which is used in conjunction with
InvocationUtil.invokeOnStableClusterSerial(NodeEngine,
com.hazelcast.util.function.Supplier, int) to reliably broadcast the CacheConfig to all members of the cluster. |
class |
CacheDestroyOperation
Destroys the cache on the cluster or on a single node by calling
ICacheService.deleteCache(String, String, boolean). |
class |
CacheEntryIteratorOperation
Provides iterator functionality for ICache.
|
class |
CacheEntryProcessorOperation
Operation of the Cache Entry Processor.
|
class |
CacheExpireBatchBackupOperation
Used to transfer expired keys from owner replica to backup replicas.
|
class |
CacheGetAllOperation
Gets all keys from the cache.
|
class |
CacheGetAllOperationFactory
Factory implementation for
CacheGetAllOperation. |
class |
CacheGetAndRemoveOperation
Cache GetAndRemove Operation.
|
class |
CacheGetAndReplaceOperation
Cache GetAndReplace Operation.
|
class |
CacheGetConfigOperation
Gets a cache configuration or creates one, if a matching cache config is found in this member's config.
|
class |
CacheGetInvalidationMetaDataOperation |
static class |
CacheGetInvalidationMetaDataOperation.MetaDataResponse |
class |
CacheGetOperation
Cache Get Operation.
|
class |
CacheKeyIteratorOperation
Provides iterator functionality for ICache.
|
class |
CacheLegacyMergeOperation
Contains a merging entry for split-brain healing with a
CacheMergePolicy. |
class |
CacheListenerRegistrationOperation
Listener can be registered and unregistered by
CacheService. |
class |
CacheLoadAllOperation
Loads all entries of the keys to partition record store
ICacheRecordStore. |
class |
CacheLoadAllOperationFactory
Factory implementation for
CacheLoadAllOperation. |
class |
CacheManagementConfigOperation
Cache ManagementConfig Operation provides enabling/disabling the functionality of management and
statistics mxbeans of the cache.
|
class |
CacheMergeOperation
Contains multiple merging entries for split-brain healing with a
SplitBrainMergePolicy. |
class |
CacheMergeOperationFactory
Inserts the merging entries for all partitions of a member via locally invoked
CacheMergeOperation. |
class |
CacheNearCacheStateHolder
Holder for Near Cache metadata.
|
class |
CacheOperation
Base Cache Operation.
|
class |
CachePutAllBackupOperation
Cache PutAllBackup Operation is the backup operation used by load all operation.
|
class |
CachePutAllOperation |
class |
CachePutBackupOperation
Backup operation for the operation of adding cache entries into record stores.
|
class |
CachePutIfAbsentOperation
Operation implementation for calling
ICacheRecordStore.putIfAbsent(Data, Object, ExpiryPolicy, String, int). |
class |
CachePutOperation
Operation implementation for
ICacheRecordStore.put(Data, Object, ExpiryPolicy, String, int) and
ICacheRecordStore.getAndPut(Data, Object, ExpiryPolicy, String, int). |
class |
CacheRemoveAllBackupOperation
Backup operation of
CacheRemoveAllOperation. |
class |
CacheRemoveAllOperation
TODO add a proper JavaDoc
|
class |
CacheRemoveAllOperationFactory
OperationFactory implementation for RemoveAll Operations. |
class |
CacheRemoveBackupOperation
Backup operation used by remove operations.
|
class |
CacheRemoveOperation
Operation implementation for cache remove functionality.
|
class |
CacheReplaceOperation
Operator implementation for cache replace functionality.
|
class |
CacheReplicationOperation
Replication operation is the data migration operation of
CacheRecordStore. |
class |
CacheSetExpiryPolicyBackupOperation |
class |
CacheSetExpiryPolicyOperation |
class |
CacheSizeOperation
This operation implementation is for calculating the cluster size of a named cache.
|
class |
CacheSizeOperationFactory
Factory implementation of
CacheSizeOperation. |
class |
KeyBasedCacheOperation
Operations running on a single key should extend this class.
|
class |
MutatingCacheOperation
Base class for all mutable cache operations.
|
class |
OnJoinCacheOperation
Operation executed on joining members so they become aware of
CacheConfigs dynamically created via
CacheManager.createCache(String, Configuration). |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCacheRecord<V,E>
Abstract implementation of
CacheRecord with key, value and
expiration time as internal state. |
class |
CacheDataRecord
Implementation of
CacheRecord where value has an internal serialized format. |
class |
CacheObjectRecord
Implementation of
CacheRecord which has an internal object format. |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheDestroyEventContext |
| Modifier and Type | Class and Description |
|---|---|
class |
CardinalityEstimatorContainer |
| Modifier and Type | Interface and Description |
|---|---|
interface |
HyperLogLog
HyperLogLog is a redundant and highly available distributed data-structure used for cardinality estimation
purposes on unique items in significantly sized data cultures.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
HyperLogLogEncoder |
| Modifier and Type | Class and Description |
|---|---|
class |
DenseHyperLogLogEncoder
1.
|
class |
HyperLogLogImpl |
class |
SparseHyperLogLogEncoder
1.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCardinalityEstimatorOperation |
class |
AggregateBackupOperation |
class |
AggregateOperation |
class |
CardinalityEstimatorBackupAwareOperation |
class |
EstimateOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
ClientAwsConfig
Deprecated.
Use
AwsConfig instead. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractClientOperation |
class |
ClientDisconnectionOperation |
class |
ClientReAuthOperation |
class |
GetConnectedClientsOperation |
class |
OnJoinClientOperation |
class |
OperationFactoryWrapper |
| Modifier and Type | Class and Description |
|---|---|
class |
CacheAssignAndGetUuidsOperation |
class |
CacheAssignAndGetUuidsOperationFactory |
| Modifier and Type | Method and Description |
|---|---|
protected IdentifiedDataSerializable |
AddQueueConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddLockConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddEventJournalConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddCacheConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddSemaphoreConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddFlakeIdGeneratorConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddSetConfigMessageTask.getConfig() |
protected abstract IdentifiedDataSerializable |
AbstractAddConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddExecutorConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddScheduledExecutorConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddRingbufferConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddMultiMapConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddReplicatedMapConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddDurableExecutorConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddMapConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddReliableTopicConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddListConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddMerkleTreeConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddCardinalityEstimatorConfigMessageTask.getConfig() |
protected IdentifiedDataSerializable |
AddTopicConfigMessageTask.getConfig() |
| Modifier and Type | Class and Description |
|---|---|
class |
MapAssignAndGetUuidsOperation |
class |
MapAssignAndGetUuidsOperationFactory |
| Modifier and Type | Class and Description |
|---|---|
class |
VectorClock
Vector clock consisting of distinct replica logical clocks.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionContainer |
class |
CollectionEvent |
class |
CollectionEventFilter |
class |
CollectionItem |
class |
TxCollectionItem |
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionAddAllBackupOperation |
class |
CollectionAddAllOperation |
class |
CollectionAddBackupOperation |
class |
CollectionAddOperation |
class |
CollectionBackupAwareOperation |
class |
CollectionClearBackupOperation |
class |
CollectionClearOperation |
class |
CollectionCompareAndRemoveOperation |
class |
CollectionContainsOperation |
class |
CollectionGetAllOperation |
class |
CollectionIsEmptyOperation |
class |
CollectionMergeBackupOperation
Creates backups for merged collection items after split-brain healing with a
SplitBrainMergePolicy. |
class |
CollectionMergeOperation
Merges a
SplitBrainMergeTypes.CollectionMergeTypes for split-brain healing with a SplitBrainMergePolicy. |
class |
CollectionOperation |
class |
CollectionRemoveBackupOperation |
class |
CollectionRemoveOperation |
class |
CollectionReplicationOperation |
class |
CollectionSizeOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
ListContainer |
| Modifier and Type | Class and Description |
|---|---|
class |
ListAddAllOperation |
class |
ListAddOperation |
class |
ListGetOperation |
class |
ListIndexOfOperation |
class |
ListRemoveOperation |
class |
ListReplicationOperation |
class |
ListSetBackupOperation |
class |
ListSetOperation |
class |
ListSubOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
QueueContainer
The
QueueContainer contains the actual queue and provides functionalities such as :
queue functionalities
transactional operation functionalities
schedules queue destruction if it is configured to be destroyed once empty
|
class |
QueueEvent
Used for queue-wide events.
|
class |
QueueEventFilter
Provides the filtering functionality for Queue events.
|
class |
QueueItem
Queue Item.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CheckAndEvictOperation
Provides eviction functionality for Operations of Queue.
|
class |
ClearBackupOperation
Store items' ID as set when ClearOperation run.
|
class |
ClearOperation
Clears items stored by Queue.
|
class |
CompareAndRemoveBackupOperation
This class triggers backup method for items' ID.
|
class |
CompareAndRemoveOperation
This class triggers iterator and if find same item in the Queue, remove this item.
|
class |
ContainsOperation
Checks whether contain or not item in the Queue.
|
class |
DrainBackupOperation
This class stores items' ID when DrainOperation run.
|
class |
DrainOperation
This class drain items according to drain condition.
|
class |
IsEmptyOperation
check if queue is empty
|
class |
IteratorOperation
Provides iterator functionality for Queue.
|
class |
OfferBackupOperation
Backup items during offer operation.
|
class |
OfferOperation
Contains offer operation for the Queue.
|
class |
PeekOperation
Peek operation for Queue.
|
class |
PollBackupOperation
Backup items during pool operation.
|
class |
PollOperation
Pool operation for Queue.
|
class |
QueueBackupAwareOperation
This abstract class contains important methods for all Queue operations.
|
class |
QueueMergeBackupOperation
Creates backups for merged queue items after split-brain healing with a
SplitBrainMergePolicy. |
class |
QueueMergeOperation
Merges a
SplitBrainMergeTypes.QueueMergeTypes for split-brain healing with a SplitBrainMergePolicy. |
class |
QueueOperation
This class contains methods for Queue operations
such as
AddAllOperation. |
class |
QueueReplicationOperation
Replication operation for the Queue.
|
class |
RemainingCapacityOperation
Returns the remaining capacity of the queue based on config max-size
|
class |
RemoveBackupOperation
Remove backup of the Queue item.
|
class |
RemoveOperation
Remove operation for the Queue.
|
class |
SizeOperation
Notify size of the queue.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SetContainer |
| Modifier and Type | Class and Description |
|---|---|
class |
SetReplicationOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionTransactionLogRecord
This class contains Transaction log for the Collection.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CollectionCommitBackupOperation
a wrapper for running all commit backup operations at once
|
class |
CollectionCommitOperation
a wrapper for running all commit operations at once
|
class |
CollectionPrepareBackupOperation |
class |
CollectionPrepareOperation |
class |
CollectionReserveAddOperation |
class |
CollectionReserveRemoveOperation |
class |
CollectionRollbackBackupOperation |
class |
CollectionRollbackOperation |
class |
CollectionTransactionRollbackOperation |
class |
CollectionTxnAddBackupOperation |
class |
CollectionTxnAddOperation |
class |
CollectionTxnRemoveBackupOperation |
class |
CollectionTxnRemoveOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
QueueTransactionLogRecord
This class contains Transaction log for the Queue.
|
class |
TxQueueItem
Transactional Queue Item.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BaseTxnQueueOperation |
class |
QueueTransactionRollbackOperation
Transaction Rollback Operation for the Queue.
|
class |
TxnCommitBackupOperation
a wrapper for running all commit backup operations at once
|
class |
TxnCommitOperation
a wrapper for running all commit operations at once
|
class |
TxnOfferBackupOperation
Provides backup operation during transactional offer operation.
|
class |
TxnOfferOperation
Transaction commit operation for a queue offer, executed on the primary replica.
|
class |
TxnPeekOperation
Peek operation for the transactional queue.
|
class |
TxnPollBackupOperation
Provides backup operation during transactional poll operation.
|
class |
TxnPollOperation
Poll operation for the transactional queue.
|
class |
TxnPrepareBackupOperation
Provides backup operation during transactional prepare operation.
|
class |
TxnPrepareOperation
Prepare operation for the transactional queue.
|
class |
TxnReserveOfferBackupOperation
Transaction prepare operation for a queue offer, executed on the backup replica.
|
class |
TxnReserveOfferOperation
Transaction prepare operation for a queue offer, executed on the primary replica.
|
class |
TxnReservePollBackupOperation
Transaction prepare operation for a queue poll, executed on the backup replica.
|
class |
TxnReservePollOperation
Transaction prepare operation for a queue poll, executed on the primary replica.
|
class |
TxnRollbackBackupOperation
Provides backup operation during transactional rollback operation.
|
class |
TxnRollbackOperation
Rollback operation for the transactional queue.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractAtomicLongOperation |
class |
AddAndGetOperation |
class |
AtomicLongBackupAwareOperation |
class |
AtomicLongReplicationOperation |
class |
GetAndAddOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractAlterOperation |
class |
AbstractAtomicReferenceOperation |
class |
AlterAndGetOperation |
class |
AlterOperation |
class |
ApplyOperation |
class |
AtomicReferenceBackupAwareOperation |
class |
AtomicReferenceReplicationOperation |
class |
CompareAndSetOperation |
class |
GetAndAlterOperation |
class |
GetAndSetOperation |
class |
IsNullOperation |
class |
SetAndGetOperation |
class |
SetBackupOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
CountDownLatchContainer |
| Modifier and Type | Class and Description |
|---|---|
class |
AwaitOperation |
class |
CountDownLatchBackupOperation |
class |
CountDownLatchReplicationOperation |
class |
CountDownOperation |
class |
GetCountOperation |
class |
SetCountOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
LockStoreImpl |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractLockOperation |
class |
AwaitBackupOperation |
class |
BeforeAwaitBackupOperation |
class |
BeforeAwaitOperation |
class |
GetLockCountOperation |
class |
GetRemainingLeaseTimeOperation |
class |
IsLockedOperation |
class |
LocalLockCleanupOperation
Locally executed operation which unlocks a lock if it is held by a
specific owner.
|
class |
LockBackupOperation |
class |
LockOperation |
class |
LockReplicationOperation |
class |
SignalBackupOperation |
class |
SignalOperation |
class |
UnlockBackupOperation |
class |
UnlockIfLeaseExpiredOperation |
class |
UnlockOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
SemaphoreContainer |
| Modifier and Type | Class and Description |
|---|---|
class |
AcquireBackupOperation |
class |
AcquireOperation |
class |
AvailableOperation |
class |
IncreaseBackupOperation |
class |
IncreaseOperation |
class |
InitBackupOperation |
class |
InitOperation |
class |
ReduceBackupOperation |
class |
ReduceOperation |
class |
ReleaseBackupOperation |
class |
ReleaseOperation |
class |
SemaphoreBackupAwareOperation |
class |
SemaphoreBackupOperation |
class |
SemaphoreDetachMemberBackupOperation |
class |
SemaphoreDetachMemberOperation |
class |
SemaphoreOperation |
class |
SemaphoreReplicationOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBasicConfig<T extends AbstractBasicConfig>
Provides a basic configuration for a split-brain aware data structure.
|
class |
AliasedDiscoveryConfig<T extends AliasedDiscoveryConfig<T>>
Configuration for discovery strategy aliases, e.g.
|
class |
AtomicLongConfig
Contains the configuration for an
AtomicLong. |
class |
AtomicReferenceConfig
Contains the configuration for an
AtomicReference. |
class |
AwsConfig
The AWSConfig contains the configuration for AWS join mechanism.
|
class |
AzureConfig
Configuration for the Azure Discovery Strategy.
|
class |
CachePartitionLostListenerConfig
Configuration for CachePartitionLostListener
|
class |
CachePartitionLostListenerConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
CacheSimpleConfig
Simple configuration to hold parsed XML configuration.
|
static class |
CacheSimpleConfig.ExpiryPolicyFactoryConfig
Represents configuration for "ExpiryPolicyFactory".
|
static class |
CacheSimpleConfig.ExpiryPolicyFactoryConfig.DurationConfig
Represents duration configuration with duration amount and time unit
for the "TimedExpiryPolicyFactoryConfig".
|
static class |
CacheSimpleConfig.ExpiryPolicyFactoryConfig.TimedExpiryPolicyFactoryConfig
Represents configuration for time based "ExpiryPolicyFactory" with duration and time unit.
|
class |
CacheSimpleConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
CacheSimpleEntryListenerConfig
Simple configuration to hold parsed listener config.
|
class |
CacheSimpleEntryListenerConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
CardinalityEstimatorConfig
Configuration options for the
CardinalityEstimator |
class |
CollectionConfig<T extends CollectionConfig>
Provides configuration service for Collection.
|
class |
CountDownLatchConfig
Contains the configuration for an
ICountDownLatch. |
class |
DiscoveryConfig
This configuration class describes the top-level config of the discovery
SPI and its discovery strategies.
|
class |
DiscoveryConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
DiscoveryStrategyConfig
This configuration class describes a
DiscoveryStrategy
based on a parsed XML or configured manually using the config API |
class |
DurableExecutorConfig
Contains the configuration for an
DurableExecutorService. |
class |
EntryListenerConfig
Configuration for EntryListener
|
static class |
EntryListenerConfig.MapListenerToEntryListenerAdapter
Wraps a MapListener into an EntryListener.
|
class |
EntryListenerConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
EurekaConfig
Configuration for the Eureka Discovery Strategy.
|
class |
EventJournalConfig
Configuration for an event journal.
|
class |
ExecutorConfig
Contains the configuration for an
IExecutorService. |
class |
ExecutorConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
FlakeIdGeneratorConfig
The
FlakeIdGeneratorConfig contains the configuration for the member
regarding Flake ID Generator. |
class |
FlakeIdGeneratorConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
GcpConfig
Configuration for the GCP Discovery Strategy.
|
class |
HotRestartConfig
Configures the Hot Restart Persistence per Hazelcast data structure.
|
class |
ItemListenerConfig
Contains the configuration for an Item Listener.
|
class |
ItemListenerConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
KubernetesConfig
Configuration for the Kubernetes Discovery Strategy.
|
class |
ListConfig
Contains the configuration for an
IList. |
class |
ListConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
ListenerConfig
Contains the configuration for an
EventListener. |
class |
ListenerConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
LockConfig
Contains the configuration for the
ILock. |
class |
MapAttributeConfig
Contains the configuration of a custom attribute that will be extracted from a Map's entry using a given ValueExtractor.
|
class |
MapAttributeConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
MapConfig
Contains the configuration for an
IMap. |
class |
MapConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
MapIndexConfig
Contains the configuration for an index in a map.
|
class |
MapIndexConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
MapPartitionLostListenerConfig
Configuration for MapPartitionLostListener
|
class |
MapPartitionLostListenerConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
MapStoreConfig
Contains the configuration for a Map Store.
|
class |
MapStoreConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
MergePolicyConfig
Configuration for
SplitBrainMergePolicy. |
class |
MerkleTreeConfig
Configuration for a merkle tree.
|
class |
MultiMapConfig
Configuration for MultiMap.
|
class |
MultiMapConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
NearCacheConfig
Contains the configuration for a Near Cache.
|
class |
NearCacheConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
NearCachePreloaderConfig
Configuration for storing and pre-loading Near Cache keys.
|
class |
PartitioningStrategyConfig
Contains the configuration for partitioning strategy.
|
class |
PartitioningStrategyConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
PNCounterConfig
Configuration for a
PNCounter |
class |
PredicateConfig
Contains the configuration for an
Predicate. |
class |
QueryCacheConfig
Contains configuration for
QueryCache. |
class |
QueueConfig
Contains the configuration for an
IQueue. |
class |
QueueConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
QueueStoreConfig
Configuration for the
QueueStore. |
class |
QueueStoreConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
QuorumConfig
Configuration for cluster quorum, a means to protect consistency of data from network partitions.
|
class |
QuorumListenerConfig
Confiquration class for
QuorumListener
IMPORTANT: The term "quorum" simply refers to the count of members in the cluster required for an operation to succeed. |
class |
ReliableTopicConfig
Configuration for a reliable
ITopic. |
class |
ReplicatedMapConfig
Contains the configuration for an
ReplicatedMap |
class |
RingbufferConfig
Contains the configuration for the
Ringbuffer. |
class |
RingbufferStoreConfig
Configuration for the
RingbufferStore. |
class |
ScheduledExecutorConfig
Configuration options for the
IScheduledExecutorService. |
class |
SemaphoreConfig
Contains the configuration for an
ISemaphore. |
class |
SemaphoreConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
SetConfig
Contains the configuration for an
ISet. |
class |
SetConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
TopicConfig
Contains the configuration for a
ITopic. |
class |
TopicConfigReadOnly
Deprecated.
this class will be removed in 4.0; it is meant for internal usage only.
|
class |
WanConsumerConfig
Config for processing WAN events received from a target cluster.
|
class |
WanPublisherConfig
Configuration object for a WAN publisher.
|
class |
WanReplicationConfig
Configuration for WAN replication.
|
class |
WanSyncConfig
Configuration object for the WAN sync mechanism.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CPGroupInfo
Contains metadata information for Raft groups, such as group id,
group members, etc.
|
class |
CPMemberInfo
CPMember represents a member in Raft group. |
class |
MembershipChangeSchedule
When there is a membership change in the CP subsystem,
all decided membership changes of Raft groups are maintained here.
|
static class |
MembershipChangeSchedule.CPGroupMembershipChange
Contains a membership change that will be performed on a CP group
|
class |
MetadataRaftGroupSnapshot
Snapshot of the Metadata Raft group state
|
class |
RaftGroupId
Implementation of
CPGroupId. |
| Modifier and Type | Class and Description |
|---|---|
class |
RaftAtomicLongSnapshot
Snapshot of a
RaftAtomicLongService state for a Raft group |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractAtomicLongOp
Base class for operations of Raft-based atomic long
|
class |
AddAndGetOp
Operation for
IAtomicLong.addAndGet(long) |
class |
AlterOp
Operation for
IAtomicLong.alter(IFunction) |
class |
GetAndAddOp
Operation for
IAtomicLong.getAndAdd(long) (long, long)}
and IAtomicLong.get() |
class |
GetAndSetOp
Operation for
IAtomicLong.getAndSet(long) |
class |
LocalGetOp
Operation for
RaftAtomicLongProxy.localGet(QueryPolicy) |
| Modifier and Type | Class and Description |
|---|---|
class |
RaftAtomicRefSnapshot
Snapshot of a
RaftAtomicRefService state for a Raft group |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractAtomicRefOp
Base class for operations of Raft-based atomic reference
|
class |
ApplyOp
|
class |
CompareAndSetOp
Operation for
IAtomicReference.compareAndSet(Object, Object) |
class |
ContainsOp
Operation for
IAtomicReference.contains(Object) |
class |
GetOp
Operation for
IAtomicReference.get() |
class |
SetOp
Operation for
IAtomicReference.set(Object) |
| Modifier and Type | Class and Description |
|---|---|
class |
AwaitInvocationKey
Represents a
ICountDownLatch.await(long, TimeUnit)} invocation |
class |
RaftCountDownLatch
State-machine implementation of the Raft-based count down latch
|
class |
RaftCountDownLatchRegistry
Contains
RaftCountDownLatch resources and manages wait timeouts |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCountDownLatchOp
Base class for operations of Raft-based count down latch
|
class |
AwaitOp
Operation for
ICountDownLatch.await(long, TimeUnit) |
class |
CountDownOp
Operation for
ICountDownLatch.countDown() |
class |
GetCountOp
Operation for
ICountDownLatch.getCount() |
class |
GetRoundOp
Operation used by
ICountDownLatch.countDown() |
class |
TrySetCountOp
Operation for
ICountDownLatch.trySetCount(int) |
| Modifier and Type | Class and Description |
|---|---|
class |
LockEndpoint
LockEndpoint represents a thread in a Raft client.
|
class |
LockInvocationKey
Represents lock() invocation of a LockEndpoint.
|
class |
RaftLock
State-machine implementation of the Raft-based lock
|
class |
RaftLockOwnershipState
Represents ownership state of a RaftLock
|
| Modifier and Type | Class and Description |
|---|---|
class |
GetLockOwnershipStateOp |
class |
LockOp
Operation for
FencedLock.lock() |
class |
TryLockOp
Operation for
FencedLock.lock() |
class |
UnlockOp
Operation for
FencedLock.unlock() |
| Modifier and Type | Class and Description |
|---|---|
class |
AcquireInvocationKey
Represents acquire() invocation of a semaphore endpoint.
|
class |
RaftSemaphore
State-machine implementation of the Raft-based semaphore.
|
class |
RaftSemaphoreRegistry
Contains
RaftSemaphore resources and manages wait timeouts
based on acquire / release requests |
class |
SemaphoreEndpoint
SemaphoreEndpoint represents a thread in a Raft client.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AcquirePermitsOp
Operation for
ISemaphore.acquire() |
class |
AvailablePermitsOp
Operation for
ISemaphore.availablePermits() |
class |
ChangePermitsOp
Operation for
ISemaphore.increasePermits(int)
and ISemaphore.reducePermits(int) |
class |
DrainPermitsOp
Operation for
ISemaphore.drainPermits()} |
class |
InitSemaphoreOp
Operation for
ISemaphore.init(int) |
class |
ReleasePermitsOp
Operation for
ISemaphore.release() |
| Modifier and Type | Class and Description |
|---|---|
class |
WaitKeyContainer<W extends WaitKey>
Contains all wait keys for an invocation uid within the same session,
including the first invocation and its retries
|
| Modifier and Type | Class and Description |
|---|---|
class |
ExpireWaitKeysOp
Expires the given wait keys on the given blocking service.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DestroyRaftObjectOp
Destroys the distributed object with the given name
on the requested Raft group
|
| Modifier and Type | Class and Description |
|---|---|
class |
ChangeRaftGroupMembershipOp
Replicates a membership change operation to a Raft group.
|
class |
DefaultRaftReplicateOp
The operation used by
RaftInvocationManager to replicate a given
RaftOp to leader of the target Raft group. |
class |
DestroyRaftGroupOp
Replicates a
DestroyRaftGroupCmd to a Raft group. |
class |
RaftQueryOp
The operation that passes a query to leader or a follower of a Raft group.
|
class |
RaftReplicateOp
|
class |
RestartCPMemberOp
Resets CP state of a member and restarts the CP subsystem initialization process.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AppendFailureResponseOp
Carries a failure response from a Raft follower to a Raft leader
for a
AppendRequest RPC |
class |
AppendRequestOp
Carries a
AppendRequest RPC from a Raft group leader to a follower |
class |
AppendSuccessResponseOp
Carries a success response from a Raft follower to a Raft leader
for a
AppendRequest RPC |
class |
AsyncRaftOp
Base class for operation classes that will carry Raft RPCs between
Raft nodes
|
class |
InstallSnapshotOp
Carries a
InstallSnapshot RPC from a Raft group leader to a follower |
class |
PreVoteRequestOp
Carries a
PreVoteRequest RPC from a Raft candidate to a follower |
class |
PreVoteResponseOp
Carries a
PreVoteResponse from a Raft follower to a candidate |
class |
VoteRequestOp
Carries a
VoteRequest RPC from a Raft candidate to a follower |
class |
VoteResponseOp
Carries a
VoteResponse from a Raft follower to a candidate |
| Modifier and Type | Class and Description |
|---|---|
class |
DestroyRaftGroupCmd
A
RaftGroupCmd to destroy an existing Raft group. |
| Modifier and Type | Class and Description |
|---|---|
class |
UpdateRaftGroupMembersCmd
A
RaftGroupCmd to update members of an existing Raft group. |
| Modifier and Type | Class and Description |
|---|---|
class |
AppendFailureResponse
Struct for failure response to AppendEntries RPC.
|
class |
AppendRequest
Struct for AppendEntries RPC.
|
class |
AppendSuccessResponse
Struct for successful response to AppendEntries RPC.
|
class |
InstallSnapshot
Struct for InstallSnapshot RPC.
|
class |
PreVoteRequest
Struct for PreVoteRequest RPC.
|
class |
PreVoteResponse
Struct for response to PreVoteRequest RPC.
|
class |
VoteRequest
Struct for VoteRequest RPC.
|
class |
VoteResponse
Struct for response to VoteRequest RPC.
|
| Modifier and Type | Class and Description |
|---|---|
class |
LogEntry
Represents an entry in the
RaftLog. |
class |
SnapshotEntry
Represents a snapshot in the
RaftLog. |
| Modifier and Type | Class and Description |
|---|---|
class |
GetInitialRaftGroupMembersIfCurrentGroupMemberOp
When a CP member is added to a Raft group, a new member list is committed to
the Raft group first.
|
class |
NotifyTermChangeOp
When leader of a Raft group changes, this operation is automatically
committed to the Raft group so that related services can perform some
actions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AddCPMemberOp
A
RaftOp that adds a new CP member to the CP subsystem. |
class |
CompleteDestroyRaftGroupsOp
Marks the given Raft groups as
CPGroup.CPGroupStatus.DESTROYED
and notifies its CP members |
class |
CompleteRaftGroupMembershipChangesOp
Commits the given successfully-applied membership changes to the Metadata
Raft group.
|
class |
CreateRaftGroupOp
Creates a new Raft group with the given name and the members and returns
its ID.
|
class |
CreateRaftNodeOp
On creation of a new Raft group or a membership change in an existing Raft
group, this operation is sent to the new members of the Raft group to
initiate the
RaftNode on the new member. |
class |
DestroyRaftNodesOp
When a Raft group is destroyed, its members terminate their internal
RaftNode instances. |
class |
ForceDestroyRaftGroupOp
If a Raft node loses its majority completely, its remaining members cannot
leave the CP subsystem gracefully.
|
class |
GetActiveCPMembersOp
Returns the current active CP members in the Metadata group.
|
class |
GetActiveRaftGroupByNameOp
Returns an active CP group by its name
|
class |
GetActiveRaftGroupIdsOp
Returns ids of the active Raft groups.
|
class |
GetDestroyingRaftGroupIdsOp
Returns ids of the Raft groups that are currently being destroyed.
|
class |
GetMembershipChangeScheduleOp
Returns the list of pending membership changes that will be orchestrated by
the leader node of the Metadata group.
|
class |
GetRaftGroupIdsOp
Returns ids of the Raft groups.
|
class |
GetRaftGroupOp
Returns information about the queried Raft group.
|
class |
InitMetadataRaftGroupOp
Used during cluster startup by CP members to commit their CP member list
to the Metadata group.
|
class |
PublishActiveCPMembersOp
CP members use this operation to broadcast their current active CP member
list to the AP Hazelcast members.
|
class |
RaftServicePreJoinOp
If the CP subsystem discovery process is completed, new Hazelcast nodes
skip the discovery step.
|
class |
RemoveCPMemberOp
When a CP member is shutting down gracefully, or a crashed CP member is
removed from the CP subsystem via
RaftService.removeCPMember(String), this operation is
committed to the Metadata Raft group. |
class |
TriggerDestroyRaftGroupOp
Initiates the destroy process for the given Raft group.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RestoreSnapshotOp
RaftOp to restore snapshot using related
SnapshotAwareService.takeSnapshot(CPGroupId, long). |
| Modifier and Type | Class and Description |
|---|---|
class |
CPSessionInfo
Represents state of a CP session.
|
class |
SessionResponse
Represents information of a session that is just created.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CloseInactiveSessionsOp
Closes inactive sessions.
|
class |
CloseSessionOp
Closes the given session on the Raft group and notifies services
via the
SessionAwareService interface. |
class |
CreateSessionOp
Creates a new session for the given endpoint and returns its id.
|
class |
ExpireSessionsOp
Expires sessions that do have not committed any heartbeat for
CPSubsystemConfig.getSessionTimeToLiveSeconds() seconds. |
class |
GenerateThreadIdOp
Operation for generating a cluster-wide unique thread id for the caller.
|
class |
GetSessionsOp
Returns the collection of active sessions in the given Raft group
|
class |
HeartbeatSessionOp
Pushes given session's heartbeat timeout forward.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCRDTReplicationOperation<T extends IdentifiedDataSerializable>
Base class for CRDT replication operations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCRDTReplicationOperation<T extends IdentifiedDataSerializable>
Base class for CRDT replication operations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PNCounterImpl
PN (Positive-Negative) CRDT counter where each replica is identified by
a String.
|
class |
PNCounterReplicationOperation
CRDT replication operation for a
PNCounter. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractPNCounterOperation
Base class for
PNCounter query and
mutation operation implementations. |
class |
AddOperation
Addition/subtraction operation for a
PNCounter. |
class |
CRDTTimestampedLong
Response for CRDT PN counter operations which contains the PN counter
value as well as the current replica vector clock.
|
class |
GetOperation
Query operation to retrieve the current value of the
PNCounter. |
| Modifier and Type | Class and Description |
|---|---|
class |
DisposeResultBackupOperation |
class |
DisposeResultOperation |
class |
PutResultBackupOperation |
class |
PutResultOperation |
class |
RetrieveAndDisposeResultOperation |
class |
RetrieveResultOperation
Used to retrieve the response of an execution with the given sequence
|
class |
ShutdownOperation |
class |
TaskBackupOperation |
class |
TaskOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
RunnableAdapter<V>
|
| Modifier and Type | Class and Description |
|---|---|
class |
CallableTaskOperation |
class |
CancellationOperation |
class |
MemberCallableTaskOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
EndpointQualifier
An
EndpointQualifier is a (ProtocolType, String) tuple that uniquely identifies groups
of network connections sharing a common ProtocolType and the same network settings, when Hazelcast
is configured with AdvancedNetworkConfig enabled. |
class |
MemberImpl |
| Modifier and Type | Class and Description |
|---|---|
class |
MemcacheEntry |
| Modifier and Type | Class and Description |
|---|---|
class |
RestValue |
| Modifier and Type | Class and Description |
|---|---|
class |
MemberInfo |
| Modifier and Type | Class and Description |
|---|---|
class |
BindMessage |
class |
ClusterStateChange<T>
Wrapper object indicating a change in the cluster state - it may be cluster state change or cluster version change.
|
class |
ClusterStateTransactionLogRecord
TransactionLogRecord implementation to be used in
ClusterState transactions. |
class |
ConfigCheck
Contains enough information about Hazelcast Config to do a validation check so that clusters with different configurations
don't join.
|
class |
ExtendedBindMessage
Extended bind message, conveying information about all kinds of public
addresses per protocol type.
|
class |
JoinMessage |
class |
JoinRequest |
class |
MembersView
MembersView is a container object to carry member list and version together.
|
class |
MembersViewMetadata |
class |
SplitBrainJoinMessage
A
JoinMessage issued by the master node of a subcluster to the master of another subcluster
while searching for other clusters for split brain recovery. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
JoinOperation
Marker interface for join and post-join operations.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractJoinOperation |
class |
AuthenticationFailureOp |
class |
AuthorizationOp |
class |
BeforeJoinCheckFailureOp |
class |
CommitClusterStateOp |
class |
ConfigMismatchOp
When a node wants to join the cluster, its sends its ConfigCheck to the cluster where it is validated.
|
class |
ExplicitSuspicionOp
An operation which is sent by a member that wants to be explicitly suspected by the target.
|
class |
FetchMembersViewOp
An operation sent by the member that starts mastership claim process to fetch/gather member views of other members.
|
class |
FinalizeJoinOp
Sent by the master to all members to finalize the join operation from a joining/returning node.
|
class |
GroupMismatchOp |
class |
HeartbeatComplaintOp |
class |
HeartbeatOp
A heartbeat sent from one cluster member to another.
|
class |
JoinMastershipClaimOp |
class |
JoinRequestOp |
class |
LockClusterStateOp |
class |
MasterResponseOp
Operation sent by any node to set the master address on the receiver
|
class |
MemberAttributeChangedOp |
class |
MembersUpdateOp |
class |
MergeClustersOp |
class |
OnJoinOp |
class |
PromoteLiteMemberOp
Promotes caller lite member to a normal member.
|
class |
RollbackClusterStateOp |
class |
ShutdownNodeOp |
class |
SplitBrainMergeValidationOp
Validate whether clusters may merge to recover from a split brain, based on configuration & cluster version.
|
class |
TriggerExplicitSuspicionOp
An operation which is sent to trigger
ExplicitSuspicionOp on target member. |
class |
TriggerMemberListPublishOp
Requests member list publish from master node
|
class |
WhoisMasterOp |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractDynamicConfigOperation |
class |
AddDynamicConfigOperation |
class |
DynamicConfigPreJoinOperation |
| Modifier and Type | Method and Description |
|---|---|
void |
ClusterWideConfigurationService.broadcastConfig(IdentifiedDataSerializable config) |
void |
ConfigurationService.broadcastConfig(IdentifiedDataSerializable config)
Registers a dynamic configurations to all cluster members.
|
ICompletableFuture<Object> |
ClusterWideConfigurationService.broadcastConfigAsync(IdentifiedDataSerializable config) |
void |
ClusterWideConfigurationService.registerConfigLocally(IdentifiedDataSerializable newConfig,
ConfigCheckMode configCheckMode)
Register a dynamic configuration in a local member.
|
| Constructor and Description |
|---|
AddDynamicConfigOperation(IdentifiedDataSerializable config,
int memberListVersion) |
AddDynamicConfigOperationSupplier(ClusterService clusterService,
IdentifiedDataSerializable config) |
DynamicConfigPreJoinOperation(IdentifiedDataSerializable[] configs,
ConfigCheckMode configCheckMode) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ConfigSupplier<T extends IdentifiedDataSerializable>
Config supplier, which helps to match type of the config to corresponding search method.
|
interface |
Searcher<T extends IdentifiedDataSerializable>
Performs search data structures configuration based on selected search method
|
| Modifier and Type | Method and Description |
|---|---|
static <T extends IdentifiedDataSerializable> |
ConfigSearch.searcherFor(Config staticConfig,
ConfigurationService configurationService,
ConfigPatternMatcher configPatternMatcher,
boolean isStaticFirst)
Factory method for creating
Searcher instances |
static <T extends IdentifiedDataSerializable> |
ConfigSearch.supplierFor(Class<T> cls)
Factory method for providing
ConfigSupplier instances for the given config class |
| Modifier and Type | Class and Description |
|---|---|
class |
DeserializingEntry<K,V> |
class |
EventJournalInitialSubscriberState
The response for the event journal subcription.
|
class |
EventJournalReadOperation<T,J>
Reads from the map event journal in batches.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MapConfigDTO
Serializable adapter for
MapConfig |
class |
PermissionConfigDTO
DTO object that provides serialization/deserialization support
for
PermissionConfig |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractManagementOperation |
class |
AddWanConfigLegacyOperation
Operation to add a new
WanReplicationConfig at runtime. |
class |
ChangeWanStateOperation
Stop, pause or resume WAN replication for the given
wanReplicationName and targetGroupName. |
class |
ClearWanQueuesOperation
Clear WAN replication queues for the given wan replication schema and publisher
|
class |
GetMapConfigOperation
Operation to fetch Map configuration.
|
class |
ScriptExecutorOperation
Operation to execute script on the node.
|
class |
SetLicenseOperation
Operation to update license at runtime.
|
class |
ThreadDumpOperation
Operation for generating thread dumps.
|
class |
UpdateManagementCenterUrlOperation
Operation to update Management Center URL configured on the node.
|
class |
UpdateMapConfigOperation
Operation to update map configuration from Management Center.
|
class |
UpdatePermissionConfigOperation
Propagates
PermissionConfig changes to members. |
class |
WanCheckConsistencyOperation
Checking consistency of the given map for the given wan replication
schema and publisher
|
| Modifier and Type | Class and Description |
|---|---|
static class |
GetCacheEntryRequest.CacheBrowserEntryView |
static class |
GetCacheEntryRequest.GetCacheEntryViewEntryProcessor |
| Modifier and Type | Class and Description |
|---|---|
class |
BatchNearCacheInvalidation |
class |
Invalidation
Root interface for Near Cache invalidation data.
|
class |
SingleNearCacheInvalidation
Represents a single key invalidation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
MigrationInfo |
class |
NonFragmentedServiceNamespace
Internal
ServiceNamespace implementation used by partitioning system to identify
non-fragmented service structures. |
class |
PartitionReplica
PartitionReplica represents owner of a partition replica
in the partition table.
|
class |
PartitionRuntimeState |
class |
ReplicaFragmentMigrationState
Contains fragment namespaces along with their partition versions and migration data operations
|
| Modifier and Type | Class and Description |
|---|---|
class |
AssignPartitions
Sent from non-master nodes to the master to initialize the partition assignment.
|
class |
FetchPartitionStateOperation
Operation sent by the master to the cluster members to fetch their partition state.
|
class |
FinalizeMigrationOperation
Invoked locally on the source or destination of the migration to finalize the migration.
|
class |
HasOngoingMigration |
class |
MigrationCommitOperation
Sent by the master node to commit a migration on the migration destination.
|
class |
MigrationOperation
Migration operation used by Hazelcast version 3.9
It runs on the migration destination and applies the received fragments.
|
class |
MigrationRequestOperation
Migration request operation used by Hazelcast version 3.9
Sent from the master node to the partition owner.
|
class |
PartitionBackupReplicaAntiEntropyOperation |
class |
PartitionReplicaSyncRequest
The request sent from a replica to the partition owner to synchronize the replica data.
|
class |
PartitionReplicaSyncResponse
The replica synchronization response sent from the partition owner to a replica.
|
class |
PartitionReplicaSyncRetryResponse
The response to a
PartitionReplicaSyncRequest that the replica should retry. |
class |
PartitionStateOperation
Sent from the master to publish or sync the partition table state to all cluster members.
|
class |
PartitionStateVersionCheckOperation
Sent from the master to check the partition table state version on target member.
|
class |
PromotionCommitOperation
Used for committing a promotion on destination.
|
class |
PublishCompletedMigrationsOperation
Sent by master member to other cluster members to publish completed migrations
and the new partition state version.
|
class |
SafeStateCheckOperation
Checks whether a node is safe or not.
|
class |
ShutdownRequestOperation |
class |
ShutdownResponseOperation |
| Modifier and Type | Method and Description |
|---|---|
IdentifiedDataSerializable |
ArrayDataSerializableFactory.create(int typeId) |
IdentifiedDataSerializable |
ArrayDataSerializableFactory.create(int typeId,
Version version) |
| Modifier and Type | Class and Description |
|---|---|
class |
ClassData
Carries byte code of a class along with its inner classes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClassDataFinderOperation |
class |
DeployClassesOperation
Operation to distribute class definitions uploaded from client to cluster
|
| Modifier and Type | Class and Description |
|---|---|
class |
LFUEvictionPolicy
LFU eviction policy for an
IMap |
class |
LRUEvictionPolicy
LRU eviction policy for an
IMap |
class |
RandomEvictionPolicy
Random eviction policy for an
IMap |
| Modifier and Type | Class and Description |
|---|---|
class |
EntryEventFilter
Event filter which matches events for a specified entry key.
|
class |
EntryRemovingProcessor |
class |
EventListenerFilter
Event filter matching events of specified types.
|
class |
LazyMapEntry<K,V>
A
Map.Entry implementation which serializes/de-serializes key and value objects on demand. |
class |
LockAwareLazyMapEntry
Specialization of the LazyMapEntry that is LockAware.
|
class |
MapEntries
|
class |
MapKeySet |
class |
MapPartitionLostEventFilter |
class |
MapValueCollection |
class |
MerkleTreeNodeEntries
The map entries that belong to a specific merkle tree node.
|
class |
SimpleEntryView<K,V>
SimpleEntryView is an implementation of
EntryView and also it is writable. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractCursor<T>
Base class for a cursor class holding a collection of items and the next position from which to resume fetching.
|
class |
MapEntriesWithCursor
Container class for a collection of entries along with an offset from which new entries can be fetched.
|
class |
MapKeysWithCursor
Container class for a collection of keys along with an offset from which new keys can be fetched.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DeserializingEventJournalMapEvent<K,V> |
class |
InternalEventJournalMapEvent
The event journal item for map events.
|
class |
MapEventJournalReadOperation<K,V,T>
Reads from the map event journal in batches.
|
class |
MapEventJournalReadResultSetImpl<K,V,T> |
class |
MapEventJournalSubscribeOperation
Performs the initial subscription to the map event journal.
|
| Modifier and Type | Class and Description |
|---|---|
class |
UuidFilter
Compares supplied UUID with this filters' UUID to prevent unneeded delivery of an invalidation event to operation caller.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractMapOperationFactory |
class |
AccumulatorConsumerOperation
Processes remaining items in
Accumulator instances on a partition. |
class |
AddIndexBackupOperation |
class |
AddIndexOperation |
class |
AddIndexOperationFactory |
class |
AddInterceptorOperation |
class |
AwaitMapFlushOperation
IMap.flush() call waits the end of flush by using this operation. |
class |
BasePutOperation |
class |
BaseRemoveOperation |
class |
ClearNearCacheOperation
Deprecated.
|
class |
ClearOperationFactory |
class |
ContainsKeyOperation |
class |
ContainsValueOperation |
class |
ContainsValueOperationFactory |
class |
EntryBackupOperation |
class |
EntryOffloadableSetUnlockOperation
Set & Unlock processing for the EntryOperation
See the javadoc on
EntryOperation |
class |
EntryOperation
Contains implementation of the off-loadable contract for EntryProcessor execution on a single key.
|
class |
EvictAllBackupOperation
Operation which evicts all keys except locked ones.
|
class |
EvictAllOperation
Operation which evicts all keys except locked ones.
|
class |
EvictAllOperationFactory
Operation factory for evict all operations.
|
class |
EvictBackupOperation |
class |
EvictBatchBackupOperation
Used to transfer expired keys from owner replica to backup replicas.
|
class |
EvictOperation |
class |
GetEntryViewOperation |
class |
IsEmptyOperationFactory |
class |
IsKeyLoadFinishedOperation
Returns if the key loading and dispatching has finished on this partition
|
class |
IsPartitionLoadedOperation |
class |
IsPartitionLoadedOperationFactory |
class |
KeyBasedMapOperation |
class |
KeyLoadStatusOperation
Notifies record store about completion of key loading.
|
class |
KeyLoadStatusOperationFactory
Factory for
KeyLoadStatusOperation |
class |
LegacyMergeOperation
Contains a merging entry for split-brain healing with a
MapMergePolicy. |
class |
LoadAllOperation
Triggers loading values for the given keys from the defined
MapLoader. |
class |
LoadMapOperation
Triggers map loading from a map store.
|
class |
LockAwareOperation |
class |
MapClearExpiredOperation
Clears expired records.
|
class |
MapFetchEntriesOperation
Operation for fetching a chunk of entries from a single
IMap partition. |
class |
MapFetchKeysOperation
Operation for fetching a chunk of keys from a single
IMap partition. |
class |
MapFetchWithQueryOperation
Fetches by query a batch of
fetchSize items from a single partition ID for a map. |
class |
MapFlushBackupOperation
Empties backup write-behind-queues upon
IMap.flush() |
class |
MapFlushOperation
Flushes dirty entries upon call of
IMap.flush() |
class |
MapFlushOperationFactory |
class |
MapGetAllOperationFactory |
class |
MapGetInvalidationMetaDataOperation |
static class |
MapGetInvalidationMetaDataOperation.MetaDataResponse |
class |
MapIsEmptyOperation |
class |
MapLoadAllOperationFactory
Operation factory for load all operations.
|
class |
MapNearCacheStateHolder
Holder for Near Cache metadata.
|
class |
MapOperation |
class |
MapPartitionDestroyOperation
Operation to destroy the map data on the partition thread
|
class |
MapReplicationOperation
Replicates all IMap-states of this partition to a replica partition.
|
class |
MapReplicationStateHolder
Holder for raw IMap key-value pairs and their metadata.
|
class |
MapSizeOperation |
class |
MergeOperationFactory
Inserts the merging entries for all partitions of a member via locally invoked
MergeOperation. |
class |
MultipleEntryBackupOperation |
class |
MultipleEntryOperation |
class |
MultipleEntryOperationFactory |
class |
MultipleEntryWithPredicateBackupOperation |
class |
MultipleEntryWithPredicateOperation |
class |
NotifyMapFlushOperation
|
class |
PartitionWideEntryBackupOperation |
class |
PartitionWideEntryOperation
GOTCHA: This operation does NOT load missing keys from map-store for now.
|
class |
PartitionWideEntryOperationFactory |
class |
PartitionWideEntryWithPredicateBackupOperation |
class |
PartitionWideEntryWithPredicateOperation |
class |
PartitionWideEntryWithPredicateOperationFactory |
class |
PostJoinMapOperation |
static class |
PostJoinMapOperation.InterceptorInfo |
class |
PutAllBackupOperation |
class |
PutAllOperation
Inserts the
MapEntries for a single partition to the local RecordStore. |
class |
PutAllPartitionAwareOperationFactory
Inserts the
MapEntries for all partitions of a member via locally invoked PutAllOperation. |
class |
PutFromLoadAllBackupOperation
Runs on backups.
|
class |
PutFromLoadAllOperation
Puts records to map which are loaded from map store by
IMap.loadAll(boolean) |
class |
PutIfAbsentOperation |
class |
PutTransientOperation |
class |
ReadonlyKeyBasedMapOperation
Abstract
MapOperation that serves as based for readonly operations. |
class |
RemoveFromLoadAllOperation
Removes keys that are contained in the
RecordStore
from the provided list, leaving only keys which are not contained in the record store. |
class |
RemoveIfSameOperation |
class |
RemoveInterceptorOperation |
class |
ReplaceIfSameOperation |
class |
ReplaceOperation |
class |
SetOperation |
class |
SetTtlBackupOperation |
class |
SetTtlOperation |
class |
SizeOperationFactory |
class |
TriggerLoadIfNeededOperation
Triggers key loading on member with
MapKeyLoader.Role.SENDER
or MapKeyLoader.Role.SENDER_BACKUP key
loader role if keys have not yet been loaded. |
class |
TryPutOperation |
class |
TryRemoveOperation |
class |
WriteBehindStateHolder
Holder for write-behind-specific state.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
Result<T extends Result>
Result of a Query.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AggregationResult
Contains the result of the evaluation of an aggregation on a specific Partition or Node.
|
class |
Query
Object representing a Query together with all possible co-variants: like a predicate, iterationType, etc.
|
class |
QueryEventFilter
Event filter which matches map events on a specified entry key and
matching a predefined
Predicate. |
class |
QueryOperation |
class |
QueryPartitionOperation |
class |
QueryResult
Represents a result of the query execution in the form of an iterable
collection of
rows. |
class |
QueryResultRow
This interfaces provides methods related to entry of the query result.
|
class |
ResultSegment
Represents a partial query result on a segment of the map.
|
class |
Target
Target for a query.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DestroyQueryCacheOperation
This operation removes all
QueryCache resources on a node. |
class |
MadePublishableOperation
Sets
AccumulatorInfo.publishable to true. |
class |
MadePublishableOperationFactory
Operation factory for
MadePublishableOperation. |
class |
PublisherCreateOperation
An idempotent create operation which creates publisher side functionality.
|
class |
ReadAndResetAccumulatorOperation
Reads all available items from the accumulator of the partition and resets it.
|
class |
SetReadCursorOperation
Sets read cursor of
Accumulator in this partition to the supplied sequence number. |
| Modifier and Type | Class and Description |
|---|---|
class |
RecordInfo
Record info.
|
class |
RecordReplicationInfo |
| Modifier and Type | Class and Description |
|---|---|
class |
MapTransactionLogRecord
Represents an operation on the map in the transaction log.
|
class |
TxnDeleteOperation
Transactional delete operation
|
class |
TxnSetOperation
An operation to unlock and set (key,value) on the partition .
|
class |
TxnUnlockBackupOperation
An operation to unlock key on the backup owner.
|
class |
TxnUnlockOperation
An operation to unlock key on the partition owner.
|
class |
VersionedValue
Wrapper for
Data value objects with version information. |
| Modifier and Type | Class and Description |
|---|---|
class |
MapReplicationRemove |
class |
MapReplicationUpdate
WAN replication object for map update operations.
|
class |
WanMapEntryView<K,V>
WAN heap based implementation of
EntryView for keeping
compatibility when sending to older (3.8+) clusters. |
| Modifier and Type | Class and Description |
|---|---|
class |
HigherHitsMapMergePolicy
Merges map entries from source to destination map if the source entry
has more hits than the destination one.
|
class |
IgnoreMergingEntryMapMergePolicy
Ignores the merging entry while collecting merge-needed entries on merging side.
|
class |
LatestUpdateMapMergePolicy
Merges map entries from source to destination map if the source entry
was updated more recently than the destination entry.
|
class |
PassThroughMergePolicy
Merges map entries from source to destination directly unless the merging entry is
null. |
class |
PutIfAbsentMapMergePolicy
Merges map entries from source to destination if they don't exist in the destination map.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AcceptAllSupplier<KeyIn,ValueIn,ValueOut>
A standard implementation of the
Supplier
interface which accepts all input values and may apply a given
PropertyExtractor on those. |
class |
AvgTuple<F,S>
Internal tuple type for average calculations, used to transmit data between
Combiner and Reducer implementations.
|
class |
KeyPredicateSupplier<KeyIn,ValueIn,ValueOut>
The default supplier for
KeyPredicates, used
to filter and optionally transform data (using the given
Supplier). |
class |
PredicateSupplier<KeyIn,ValueIn,ValueOut>
|
class |
SetAdapter<E>
A simple adapter class to serialize values of a
Set using
Hazelcast serialization support. |
| Modifier and Type | Class and Description |
|---|---|
class |
CombinerResultList<E>
|
class |
HashMapAdapter<K,V>
Simple HashMap adapter class to implement DataSerializable serialization semantics
to not loose hands on serialization while sending intermediate results.
|
class |
ListKeyValueSource<V>
This
KeyValueSource implementation is used in
KeyValueSource.fromList(com.hazelcast.core.IList) to generate a default
implementation based on a Hazelcast IList. |
class |
MapKeyValueSource<K,V>
This
KeyValueSource implementation is used in
KeyValueSource.fromMap(com.hazelcast.core.IMap) to generate a default
implementation based on a Hazelcast IMap. |
class |
MultiMapKeyValueSource<K,V>
This
KeyValueSource implementation is used in
KeyValueSource.fromMultiMap(com.hazelcast.core.MultiMap) to generate a default
implementation based on a Hazelcast MultiMap. |
class |
SetKeyValueSource<V>
This
KeyValueSource implementation is used in
KeyValueSource.fromSet(com.hazelcast.core.ISet) to generate a default
implementation based on a Hazelcast ISet. |
| Modifier and Type | Class and Description |
|---|---|
class |
IntermediateChunkNotification<KeyOut,Value>
Notification that is fired every time the chunk limit is reached and is send to the reducers
|
class |
LastChunkNotification<KeyOut,Value>
This notification is used to notify the reducer that this chunk is the last chunk of the
defined partitionId.
|
class |
MapReduceNotification
Base class for all map reduce framework notifications
|
class |
MemberAwareMapReduceNotification
Base class for all notifications based on a member
|
class |
ReducingFinishedNotification
This notification class is used to signal the
JobSupervisor
owner node that a reducer has finished the reducing step for the defined partitionId. |
| Modifier and Type | Class and Description |
|---|---|
class |
CancelJobSupervisorOperation
This operation is fired by the jobs owner node to remotely cancel the defined jobId on all nodes.
|
class |
FireNotificationOperation
This operation is used to transport and execute a notification on a remote node since
the current event service is not capable of reliable transmission so this is a fallback
to sync operations which is hopefully only a temporary workaround!
|
class |
GetResultOperationFactory
This class is used to create
GetResultOperation instances. |
class |
KeysAssignmentOperation
This operation is used to request assignment for keys on the job owners node.
|
class |
KeysAssignmentResult
This class is used to store assignment results in
KeysAssignmentOperation
executions. |
class |
KeyValueJobOperation<K,V>
This operation is used to prepare a
KeyValueSource based
map reduce operation on all cluster members. |
class |
NotifyRemoteExceptionOperation
This operation is used to inform the job owner of a remote exception
|
class |
PostPonePartitionProcessing
This operation is used to tell the job owner to postpone a mapping phase for the defined
partitionId.
|
class |
ProcessingOperation
This is the base class for all map reduce framework operations, it always contains the name of
the JobTracker and the unique jobId
|
class |
ProcessStatsUpdateOperation
This operation is used to update the process statistics on the owner node
|
class |
RequestMemberIdAssignment
This operation is used to do some kind of partitionId based processing on non partition based implementations
of
KeyValueSource (not implementing PartitionIdAware)
which can happen for custom data sources like distributed filesystems that are up to the end user on how to
manage the distribution. |
class |
RequestPartitionMapping
This operation requests a new partition to process by the requester on the job owning node
|
class |
RequestPartitionProcessed
This operation tells the job owner to mark a partition as fully processed
|
class |
RequestPartitionReducing
This operation tells the job owner to start reducing phase of the defined partition on the first
occurrence of a full emitted chunk
|
class |
RequestPartitionResult
This class is used to store the requested result of all kinds of processing operations.
By default it holds a basic result state and maybe the partitionId it was operated otherwise it's value is defined as -1 |
class |
StartProcessingJobOperation<K>
This operation is used to start the actual processing after all node prepared to execute the map reduce job
|
| Modifier and Type | Class and Description |
|---|---|
class |
MultiMapEventFilter |
class |
MultiMapMergeContainer
Container for the merge operation of a
MultiMap. |
class |
MultiMapRecord |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBackupAwareMultiMapOperation |
class |
AbstractKeyBasedMultiMapOperation |
class |
AbstractMultiMapOperation |
class |
ContainsEntryOperation |
class |
CountOperation |
class |
DeleteBackupOperation |
class |
DeleteOperation |
class |
EntrySetOperation |
class |
EntrySetResponse |
class |
GetAllOperation |
class |
KeySetOperation |
class |
MultiMapOperationFactory |
class |
MultiMapReplicationOperation |
class |
MultiMapResponse |
class |
PutBackupOperation |
class |
PutOperation |
class |
RemoveAllBackupOperation |
class |
RemoveAllOperation |
class |
ValuesOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
MultiMapTransactionLogRecord |
class |
TxnGenerateRecordIdOperation |
class |
TxnLockAndGetOperation |
class |
TxnPutBackupOperation |
class |
TxnPutOperation |
class |
TxnRemoveAllBackupOperation |
class |
TxnRemoveAllOperation |
class |
TxnRemoveBackupOperation |
class |
TxnRemoveOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
Address
Represents an address of a member in the cluster.
|
| Modifier and Type | Method and Description |
|---|---|
IdentifiedDataSerializable |
DataSerializableFactory.create(int typeId)
Creates an IdentifiedDataSerializable instance using given type ID
|
| Modifier and Type | Method and Description |
|---|---|
IdentifiedDataSerializable |
VersionedDataSerializableFactory.create(int typeId,
Version version)
Creates an IdentifiedDataSerializable instance using given type ID and object version
|
| Modifier and Type | Class and Description |
|---|---|
class |
IdentityProjection<I> |
class |
MultiAttributeProjection<I>
Projection that extracts the values of the given attributes and returns them in an Object[] array.
|
class |
SingleAttributeProjection<I,O>
Projection that extracts the values of the given attribute and returns it.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PagingPredicate<K,V>
This class is a special Predicate which helps to get a page-by-page result of a query.
|
class |
PartitionPredicate<K,V>
A
Predicate that restricts the execution of a Predicate to a single Partition. |
class |
SqlPredicate
This class contains methods related to conversion of sql query to predicate.
|
class |
TruePredicate<K,V>
A
Predicate which always returns true. |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ComparableIdentifiedDataSerializable
Defines a contract of objects that are simultaneously
Comparable and
IdentifiedDataSerializable. |
| Modifier and Type | Class and Description |
|---|---|
class |
CompositeValue
Represents a composite value composed out of a value tuple called components.
|
class |
FalsePredicate<K,V>
A
Predicate which always returns false. |
class |
IndexInfo |
class |
MapIndexInfo |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractIndexAwarePredicate<K,V> |
class |
AbstractPredicate<K,V>
Provides base features for predicates, such as extraction and conversion of the attribute's value.
|
class |
AndPredicate
And Predicate
|
class |
BetweenPredicate
Between Predicate
|
class |
BoundedRangePredicate
Range predicate that is bounded on both sides.
|
class |
EqualPredicate
Equal Predicate
|
class |
GreaterLessPredicate
Greater Less Predicate
|
class |
ILikePredicate
Ilike Predicate
|
class |
InPredicate
In Predicate
|
class |
InstanceOfPredicate
Predicate version of `instaceof` operator from Java.
|
class |
LikePredicate
Like Predicate
|
class |
NotEqualPredicate
Not Equal Predicate
|
class |
NotPredicate
Not Predicate
|
class |
OrPredicate
Or Predicate
|
class |
RegexPredicate
Regex Predicate
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractNamedSerializableOperation |
class |
AbstractReplicatedMapOperation |
class |
AbstractSerializableOperation |
class |
CheckReplicaVersionOperation
Checks whether replica version is in sync with the primary.
|
class |
EvictionOperation
Evicts set of entries from the record store.
|
class |
PutAllOperationFactory
Factory class for
PutAllOperation. |
class |
ReplicateUpdateOperation
Replicates the update happened on the partition owner to the other nodes.
|
class |
ReplicateUpdateToCallerOperation
This operation will update the local record store with the update received from local/remote partition owner.
|
class |
RequestMapDataOperation
Collects and sends the replicated map data from the executing node to the caller via
SyncReplicatedMapDataOperation. |
class |
SyncReplicatedMapDataOperation<K,V>
Carries set of replicated map records for a partition from one node to another
|
class |
VersionResponsePair
Contains response and partition version for update operations on replicated map.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RecordMigrationInfo |
class |
ReplicatedMapEntryView<K,V> |
| Modifier and Type | Class and Description |
|---|---|
class |
ReadResultSetImpl<O,E>
A list for the
ReadManyOperation. |
class |
RingbufferContainer<T,E>
The RingbufferContainer is responsible for the functionalities supporting
the underlying ringbuffer structure containing the data.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractRingBufferOperation
Common logic for all ring buffer operations :
getting the ring buffer container or creating a new one if necessary
serialization/deserialization of ring buffer name
defines the factory ID for the
IdentifiedDataSerializable
|
class |
AddAllBackupOperation
Backup operation for ring buffer
AddAllOperation. |
class |
AddAllOperation
Adds a batch of items to the ring buffer.
|
class |
AddBackupOperation
Backup operation for ring buffer
AddOperation. |
class |
GenericOperation
Ring buffer operations which don't need to send any parameters and which can be determined by only sending the operation
type which is a byte of information.
|
class |
MergeBackupOperation
Contains the entire ringbuffer as a result of split-brain healing with a
SplitBrainMergePolicy. |
class |
MergeOperation
Contains an entire ringbuffer for split-brain healing with a
SplitBrainMergePolicy. |
class |
ReadManyOperation<O> |
class |
ReadOneOperation |
class |
ReplicationOperation |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ScheduledTaskStatistics
Statistics and timing info for a
IScheduledFuture accessible through IScheduledFuture.getStats() |
| Modifier and Type | Class and Description |
|---|---|
class |
ScheduledTaskHandler
Resource handler pointing to a
IScheduledFuture. |
| Modifier and Type | Class and Description |
|---|---|
class |
NamedTaskDecorator<V> |
class |
ScheduledRunnableAdapter<V> |
class |
ScheduledTaskDescriptor
Metadata holder for scheduled tasks.
|
class |
ScheduledTaskHandlerImpl |
class |
ScheduledTaskResult |
class |
ScheduledTaskStatisticsImpl |
class |
TaskDefinition<V> |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBackupAwareSchedulerOperation |
class |
AbstractGetAllScheduledOperation |
class |
AbstractSchedulerOperation |
class |
CancelTaskBackupOperation |
class |
CancelTaskOperation |
class |
DisposeBackupTaskOperation |
class |
DisposeTaskOperation |
class |
GetAllScheduledOnMemberOperation |
class |
GetAllScheduledOnPartitionOperation |
class |
GetAllScheduledOnPartitionOperationFactory |
class |
GetDelayOperation |
class |
GetResultOperation<V> |
class |
GetStatisticsOperation |
class |
IsCanceledOperation |
class |
IsDoneOperation |
class |
ResultReadyNotifyOperation<V> |
class |
ScheduleTaskBackupOperation |
class |
ScheduleTaskOperation |
class |
SyncBackupStateOperation |
class |
SyncStateOperation |
| Modifier and Type | Interface and Description |
|---|---|
interface |
OperationFactory
A Factory for creating
Operation instances. |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractLocalOperation
Abstract class for local operations, which should not be serializable.
|
class |
DistributedObjectNamespace
Default
ObjectNamespace implementation for DistributedObject. |
class |
OperationControl
Content of an Operation Control packet:
a list of operations the remote member started on this member which are still running;
a list of operations this member wants to cancel on the remote member.
Operations are identified by their call ID.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractNamedOperation |
class |
BinaryOperationFactory
An
OperationFactory that creates operations by cloning
the passed Operation. |
class |
SerializableList |
class |
UnmodifiableLazyList<E> |
| Modifier and Type | Class and Description |
|---|---|
class |
EventEnvelope
An Envelope around an event object.
|
class |
TrueEventFilter
An event filter which does not filter any event and always evaluates
true results. |
| Modifier and Type | Class and Description |
|---|---|
class |
DeregistrationOperation |
class |
OnJoinRegistrationOperation |
class |
RegistrationOperation |
class |
SendEventOperation
An operation for sending a event to a remote subscriber (not on this node).
|
| Modifier and Type | Class and Description |
|---|---|
class |
Backup |
class |
PartitionAwareOperationFactory
Creates partition specific operations.
|
class |
PartitionIteratingOperation
Executes Operations on one or more partitions.
|
static class |
PartitionIteratingOperation.PartitionResponse |
| Modifier and Type | Class and Description |
|---|---|
class |
BackupAckResponse
The {Response} for a
BackupOperation. |
class |
CallTimeoutResponse
An response that indicates that the execution of a single call ran into a timeout.
|
class |
ErrorResponse |
class |
NormalResponse
A NormalResponse is send when an Operation needs to return a value.
|
class |
Response
|
| Modifier and Type | Class and Description |
|---|---|
class |
DistributedObjectDestroyOperation |
class |
InitializeDistributedObjectOperation |
class |
PostJoinProxyOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
DiscardMergePolicy<V,T extends MergingValue<V>>
Merges only entries from the destination data structure and discards all entries from the source data structure.
|
class |
ExpirationTimeMergePolicy<V,T extends MergingExpirationTime<V>>
Merges data structure entries from source to destination data structure if the source entry
will expire later than the destination entry.
|
class |
HigherHitsMergePolicy<V,T extends MergingHits<V>>
Merges data structure entries from source to destination data structure if the source entry
has more hits than the destination one.
|
class |
HyperLogLogMergePolicy
Only available for HyperLogLog backed
CardinalityEstimator. |
class |
LatestAccessMergePolicy<V,T extends MergingLastAccessTime<V>>
Merges data structure entries from source to destination data structure if the source entry
has been accessed more recently than the destination entry.
|
class |
LatestUpdateMergePolicy<V,T extends MergingLastUpdateTime<V>>
Merges data structure entries from source to destination data structure if the source entry
was updated more frequently than the destination entry.
|
class |
PutIfAbsentMergePolicy<V,T extends MergingValue<V>>
Merges data structure entries from source to destination if they don't exist in the destination data structure.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PublishOperation
ITopic publication operation used when global ordering is enabled
(all nodes listening to the same topic get their messages in the same order).
|
| Modifier and Type | Class and Description |
|---|---|
class |
ReliableTopicMessage
The Object that is going to be stored in the Ringbuffer.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
TargetAwareTransactionLogRecord
Represents a change made in a transaction on a specific target Address.
|
interface |
TransactionLogRecord
Represents a change made in a transaction e.g.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractTxOperation |
class |
BroadcastTxRollbackOperation |
class |
CreateAllowedDuringPassiveStateTxBackupLogOperation |
class |
CreateTxBackupLogOperation |
class |
PurgeAllowedDuringPassiveStateTxBackupLogOperation |
class |
PurgeTxBackupLogOperation |
class |
ReplicateAllowedDuringPassiveStateTxBackupLogOperation |
class |
ReplicateTxBackupLogOperation
Replicates the transactionlog to a remote system.
|
class |
RollbackAllowedDuringPassiveStateTxBackupLogOperation |
class |
RollbackTxBackupLogOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
XATransactionDTO |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractXAOperation |
class |
ClearRemoteTransactionBackupOperation |
class |
ClearRemoteTransactionOperation |
class |
CollectRemoteTransactionsOperation |
class |
FinalizeRemoteTransactionBackupOperation |
class |
FinalizeRemoteTransactionOperation |
class |
PutRemoteTransactionBackupOperation |
class |
PutRemoteTransactionOperation |
class |
XaReplicationOperation |
| Modifier and Type | Class and Description |
|---|---|
class |
MemberVersion
Determines the Hazelcast codebase version in terms of major.minor.patch version.
|
class |
Version
A generic version to be used with
VersionAware classes. |
| Modifier and Type | Class and Description |
|---|---|
class |
WanReplicationEvent
Event class used to transmit the actual event object
|
Copyright © 2020 Hazelcast, Inc.. All Rights Reserved.