S
- public abstract class AbstractDistributedObject<S extends RemoteService> extends Object implements DistributedObject
Modifier and Type | Field and Description |
---|---|
protected static PartitioningStrategy |
PARTITIONING_STRATEGY |
Modifier | Constructor and Description |
---|---|
protected |
AbstractDistributedObject(NodeEngine nodeEngine,
S service) |
Modifier and Type | Method and Description |
---|---|
void |
destroy()
Destroys this object cluster-wide.
|
boolean |
equals(Object o) |
protected String |
getDistributedObjectName() |
protected Data |
getNameAsPartitionAwareData() |
NodeEngine |
getNodeEngine()
Gets the node engine.
|
OperationService |
getOperationService()
Gets the OperationService.
|
protected int |
getPartitionId(Data key) |
String |
getPartitionKey()
Returns the key of the partition that this DistributedObject is assigned to.
|
S |
getService()
Gets the Service of this AbstractDistributedObject.
|
abstract String |
getServiceName()
Returns the service name for this object.
|
int |
hashCode() |
void |
invalidate() |
protected <E> InternalCompletableFuture<E> |
invokeOnPartition(Operation operation) |
protected boolean |
isClusterVersionEqualTo(Version version) |
protected boolean |
isClusterVersionGreaterOrEqual(Version version) |
protected boolean |
isClusterVersionGreaterThan(Version version) |
protected boolean |
isClusterVersionLessOrEqual(Version version) |
protected boolean |
isClusterVersionLessThan(Version version) |
protected boolean |
isClusterVersionUnknown() |
protected boolean |
isClusterVersionUnknownOrGreaterOrEqual(Version version) |
protected boolean |
isClusterVersionUnknownOrGreaterThan(Version version) |
protected boolean |
isClusterVersionUnknownOrLessOrEqual(Version version) |
protected boolean |
isClusterVersionUnknownOrLessThan(Version version) |
protected void |
postDestroy() |
protected boolean |
preDestroy() |
protected void |
throwNotActiveException() |
protected Data |
toData(Object object) |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
getName
protected static final PartitioningStrategy PARTITIONING_STRATEGY
protected AbstractDistributedObject(NodeEngine nodeEngine, S service)
protected String getDistributedObjectName()
protected Data getNameAsPartitionAwareData()
public String getPartitionKey()
DistributedObject
IAtomicLong
. For a partitioned data structure like an IMap
,
the returned value will not be null, but otherwise undefined.getPartitionKey
in interface DistributedObject
public final void destroy()
DistributedObject
destroy
in interface DistributedObject
protected final <E> InternalCompletableFuture<E> invokeOnPartition(Operation operation)
protected final int getPartitionId(Data key)
protected boolean preDestroy()
protected void postDestroy()
public final NodeEngine getNodeEngine()
HazelcastInstanceNotActiveException
- if NodeEngine not active or DistributedObject destroyed.protected void throwNotActiveException()
public final S getService()
HazelcastInstanceNotActiveException
- if object is destroyed or HazelcastInstance shutdown.public final OperationService getOperationService()
HazelcastInstanceNotActiveException
- if object is destroyed or HazelcastInstance shutdown.public abstract String getServiceName()
DistributedObject
getServiceName
in interface DistributedObject
public final void invalidate()
protected boolean isClusterVersionLessThan(Version version)
protected boolean isClusterVersionUnknownOrLessThan(Version version)
protected boolean isClusterVersionLessOrEqual(Version version)
protected boolean isClusterVersionUnknownOrLessOrEqual(Version version)
protected boolean isClusterVersionGreaterThan(Version version)
protected boolean isClusterVersionUnknownOrGreaterThan(Version version)
protected boolean isClusterVersionGreaterOrEqual(Version version)
protected boolean isClusterVersionUnknownOrGreaterOrEqual(Version version)
protected boolean isClusterVersionEqualTo(Version version)
protected boolean isClusterVersionUnknown()
Copyright © 2022 Hazelcast, Inc.. All Rights Reserved.