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, waitgetNameprotected static final PartitioningStrategy PARTITIONING_STRATEGY
protected AbstractDistributedObject(NodeEngine nodeEngine, S service)
protected String getDistributedObjectName()
protected Data getNameAsPartitionAwareData()
public String getPartitionKey()
DistributedObjectIAtomicLong. For a partitioned data structure like an IMap,
the returned value will not be null, but otherwise undefined.getPartitionKey in interface DistributedObjectpublic final void destroy()
DistributedObjectdestroy in interface DistributedObjectprotected 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()
DistributedObjectgetServiceName in interface DistributedObjectpublic 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 © 2019 Hazelcast, Inc.. All Rights Reserved.