Package | Description |
---|---|
com.hazelcast.cache.impl |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.cache.impl.operation |
Hazelcast JSR-107 aka JCache implementation
|
com.hazelcast.internal.locksupport | |
com.hazelcast.internal.locksupport.operations |
This package contains the operations for the Lock support.
|
com.hazelcast.internal.partition |
Contains the internals for partition assignment/management, migration, replication etc.
|
com.hazelcast.internal.partition.impl |
Contains the actual implementation of the
InternalPartitionService . |
com.hazelcast.internal.partition.operation |
Contains the operations for partition package.
|
com.hazelcast.internal.services |
Provides interfaces/classes for building distributed data structures and services.
|
com.hazelcast.map.impl |
Contains implementation specific classes of
com.hazelcast.map package. |
com.hazelcast.map.impl.operation |
Package for map operations.
|
com.hazelcast.multimap.impl |
Contains classes for Hazelcast MultiMap module.
|
com.hazelcast.ringbuffer.impl |
Contains the
Ringbuffer implementation classes. |
com.hazelcast.ringbuffer.impl.operations | |
com.hazelcast.spi.impl |
Contains implementations for Hazelcast SPI.
|
com.hazelcast.spi.partition |
Contains the SPI for partition logic for Hazelcast.
|
com.hazelcast.wan |
This package contains the WAN replication API
|
com.hazelcast.wan.impl |
This package contains the opensource implementation of WAN replication
|
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
CachePartitionSegment.getAllNamespaces(int replicaIndex) |
Collection<ServiceNamespace> |
CacheService.getAllServiceNamespaces(PartitionReplicationEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
CacheService.isKnownServiceNamespace(ServiceNamespace namespace) |
Modifier and Type | Method and Description |
---|---|
Operation |
CacheService.prepareReplicationOperation(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces) |
Modifier and Type | Method and Description |
---|---|
void |
CacheReplicationOperation.prepare(CachePartitionSegment segment,
Collection<ServiceNamespace> namespaces,
int replicaIndex) |
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
LockStoreContainer.getAllNamespaces(int replicaIndex) |
Collection<ServiceNamespace> |
LockSupportServiceImpl.getAllServiceNamespaces(PartitionReplicationEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
LockSupportServiceImpl.isKnownServiceNamespace(ServiceNamespace namespace) |
Modifier and Type | Method and Description |
---|---|
Operation |
LockSupportServiceImpl.prepareReplicationOperation(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces) |
Modifier and Type | Method and Description |
---|---|
ServiceNamespace |
AbstractLockOperation.getServiceNamespace() |
Constructor and Description |
---|
LockReplicationOperation(LockStoreContainer container,
int partitionId,
int replicaIndex,
Collection<ServiceNamespace> namespaces) |
Modifier and Type | Class and Description |
---|---|
class |
NonFragmentedServiceNamespace
Internal
ServiceNamespace implementation used by partitioning system to identify
non-fragmented service structures. |
Modifier and Type | Method and Description |
---|---|
ServiceNamespace |
PartitionReplicaVersionManager.getServiceNamespace(Operation operation)
Returns
ServiceNamespace for given operation. |
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
PartitionReplicaVersionManager.getNamespaces(int partitionId)
Returns all registered namespaces for given partition ID
|
Map<ServiceNamespace,long[]> |
ReplicaFragmentMigrationState.getNamespaceVersionMap() |
Modifier and Type | Method and Description |
---|---|
long[] |
PartitionReplicaVersionManager.getPartitionReplicaVersions(int partitionId,
ServiceNamespace namespace)
Returns replica versions for given partition and namespace.
|
long[] |
PartitionReplicaVersionManager.incrementPartitionReplicaVersions(int partitionId,
ServiceNamespace namespace,
int backupCount)
Increments replica versions for given partition and namespace by the number of backup count.
|
boolean |
PartitionReplicaVersionManager.isPartitionReplicaVersionStale(int partitionId,
ServiceNamespace namespace,
long[] replicaVersions,
int replicaIndex)
Returns whether given replica version is behind the current version or not.
|
void |
PartitionReplicaVersionManager.updatePartitionReplicaVersions(int partitionId,
ServiceNamespace namespace,
long[] replicaVersions,
int replicaIndex)
Updates the partition replica version and triggers replica sync if the replica is dirty (e.g.
|
Constructor and Description |
---|
ReplicaFragmentMigrationState(Map<ServiceNamespace,long[]> namespaces,
Collection<Operation> migrationOperations) |
Modifier and Type | Method and Description |
---|---|
ServiceNamespace |
PartitionReplicaManager.getServiceNamespace(Operation operation) |
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
PartitionReplicaManager.getNamespaces(int partitionId) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionReplicaManager.clearPartitionReplicaVersions(int partitionId,
ServiceNamespace namespace) |
void |
PartitionReplicaManager.clearReplicaSyncRequest(int partitionId,
ServiceNamespace namespace,
int replicaIndex)
Resets the state of the replica synchronization request for the given partition and replica.
|
void |
PartitionReplicaManager.finalizeReplicaSync(int partitionId,
int replicaIndex,
ServiceNamespace namespace,
long[] versions)
Set the new replica versions for the partition with the
partitionId and reset any ongoing replica
synchronization request for this partition and replica index. |
long[] |
PartitionReplicaManager.getPartitionReplicaVersions(int partitionId,
ServiceNamespace namespace) |
long[] |
PartitionReplicaManager.incrementPartitionReplicaVersions(int partitionId,
ServiceNamespace namespace,
int backupCount) |
boolean |
PartitionReplicaManager.isPartitionReplicaVersionDirty(int partitionId,
ServiceNamespace namespace) |
boolean |
PartitionReplicaManager.isPartitionReplicaVersionStale(int partitionId,
ServiceNamespace namespace,
long[] versions,
int replicaIndex) |
void |
PartitionReplicaManager.setPartitionReplicaVersions(int partitionId,
ServiceNamespace namespace,
long[] versions,
int replicaOffset) |
void |
PartitionReplicaManager.updatePartitionReplicaVersions(int partitionId,
ServiceNamespace namespace,
long[] versions,
int replicaIndex) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionReplicaManager.retainNamespaces(int partitionId,
Set<ServiceNamespace> namespaces) |
void |
PartitionReplicaManager.triggerPartitionReplicaSync(int partitionId,
Collection<ServiceNamespace> namespaces,
int replicaIndex)
This method is called on a backup node (replica).
|
Constructor and Description |
---|
PartitionReplicaSyncResponse(Collection<Operation> operations,
ServiceNamespace namespace,
long[] versions) |
Constructor and Description |
---|
PartitionBackupReplicaAntiEntropyOperation(Map<ServiceNamespace,Long> versions,
boolean returnResponse) |
PartitionReplicaSyncRequest(int partitionId,
List<ServiceNamespace> namespaces,
int replicaIndex) |
PartitionReplicaSyncRetryResponse(Collection<ServiceNamespace> namespaces) |
Modifier and Type | Interface and Description |
---|---|
interface |
ObjectNamespace
An ObjectNamespace that makes identification of object within a service possible.
|
Modifier and Type | Class and Description |
---|---|
class |
DistributedObjectNamespace
Default
ObjectNamespace implementation for DistributedObject . |
Modifier and Type | Method and Description |
---|---|
ServiceNamespace |
ServiceNamespaceAware.getServiceNamespace()
Returns the
ServiceNamespace which this object belongs to. |
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
PartitionContainer.getAllNamespaces(int replicaIndex) |
Collection<ServiceNamespace> |
MapService.getAllServiceNamespaces(PartitionReplicationEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
MapService.isKnownServiceNamespace(ServiceNamespace namespace) |
Modifier and Type | Method and Description |
---|---|
Operation |
MapService.prepareReplicationOperation(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces) |
Constructor and Description |
---|
MapReplicationOperation(PartitionContainer container,
Collection<ServiceNamespace> namespaces,
int partitionId,
int replicaIndex) |
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
MultiMapPartitionContainer.getAllNamespaces(int replicaIndex) |
Collection<ServiceNamespace> |
MultiMapService.getAllServiceNamespaces(PartitionReplicationEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
MultiMapService.isKnownServiceNamespace(ServiceNamespace namespace) |
Modifier and Type | Method and Description |
---|---|
Operation |
MultiMapService.prepareReplicationOperation(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces) |
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
RingbufferService.getAllServiceNamespaces(PartitionReplicationEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
RingbufferService.isKnownServiceNamespace(ServiceNamespace namespace) |
Modifier and Type | Method and Description |
---|---|
Operation |
RingbufferService.prepareReplicationOperation(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces) |
Modifier and Type | Method and Description |
---|---|
ServiceNamespace |
MergeOperation.getServiceNamespace() |
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
CountingMigrationAwareService.getAllServiceNamespaces(PartitionReplicationEvent event) |
Modifier and Type | Method and Description |
---|---|
boolean |
CountingMigrationAwareService.isKnownServiceNamespace(ServiceNamespace namespace) |
Modifier and Type | Method and Description |
---|---|
Operation |
CountingMigrationAwareService.prepareReplicationOperation(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces) |
Modifier and Type | Method and Description |
---|---|
Collection<ServiceNamespace> |
FragmentedMigrationAwareService.getAllServiceNamespaces(PartitionReplicationEvent event)
Returns all known namespaces for given replication event.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FragmentedMigrationAwareService.isKnownServiceNamespace(ServiceNamespace namespace)
Returns true if namespace is known by this service, false otherwise
|
Modifier and Type | Method and Description |
---|---|
Operation |
FragmentedMigrationAwareService.prepareReplicationOperation(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces)
Returns an operation to replicate service data and/or state for a specific partition replica and namespaces
on another cluster member.
|
Modifier and Type | Method and Description |
---|---|
default void |
WanReplicationPublisher.collectAllServiceNamespaces(PartitionReplicationEvent event,
Set<ServiceNamespace> namespaces)
Collect the namespaces of all WAN event containers that should be replicated
by the replication event.
|
default T |
WanReplicationPublisher.prepareEventContainerReplicationData(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces)
Returns a container containing the WAN events for the given replication
event and namespaces to be replicated. |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingWanReplicationScheme.collectAllServiceNamespaces(PartitionReplicationEvent event,
Set<ServiceNamespace> namespaces)
Collect the namespaces of all queues that should be replicated by the
replication event.
|
Map<String,Object> |
DelegatingWanReplicationScheme.prepareEventContainerReplicationData(PartitionReplicationEvent event,
Collection<ServiceNamespace> namespaces)
Collect all replication data matching the replication event and collection
of namespaces being replicated.
|
Copyright © 2019 Hazelcast, Inc.. All rights reserved.