public abstract class TransactionalMapProxySupport extends AbstractDistributedObject<MapService> implements TransactionalObject
TransactionalMapProxy
Modifier and Type | Field and Description |
---|---|
protected MapServiceContext |
mapServiceContext |
protected String |
name |
protected MapOperationProvider |
operationProvider |
protected PartitioningStrategy |
partitionStrategy |
protected RecordFactory |
recordFactory |
protected Transaction |
tx |
protected Map<Data,VersionedValue> |
valueMap |
PARTITIONING_STRATEGY
Constructor and Description |
---|
TransactionalMapProxySupport(String name,
MapService mapService,
NodeEngine nodeEngine,
Transaction transaction) |
Modifier and Type | Method and Description |
---|---|
protected void |
checkTransactionState() |
boolean |
containsKeyInternal(Data key) |
Object |
getForUpdateInternal(Data key) |
Object |
getInternal(Data key) |
String |
getName()
Returns the unique name for this DistributedObject.
|
String |
getServiceName()
Returns the service name for this object.
|
protected long |
getTimeInMillis(long time,
TimeUnit timeunit) |
protected boolean |
isEquals(Object value1,
Object value2) |
Data |
putIfAbsentInternal(Data key,
Data value) |
Data |
putInternal(Data key,
Data value) |
Data |
putInternal(Data key,
Data value,
long ttl,
TimeUnit timeUnit) |
boolean |
removeIfSameInternal(Data key,
Object value) |
Data |
removeInternal(Data key) |
boolean |
replaceIfSameInternal(Data key,
Object oldValue,
Data newValue) |
Data |
replaceInternal(Data key,
Data value) |
int |
sizeInternal() |
destroy, equals, getNameAsPartitionAwareData, getNodeEngine, getOperationService, getPartitionId, getPartitionKey, getService, hashCode, invalidate, postDestroy, throwNotActiveException, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
destroy, getPartitionKey
protected final String name
protected final Transaction tx
protected final PartitioningStrategy partitionStrategy
protected final Map<Data,VersionedValue> valueMap
protected final RecordFactory recordFactory
protected final MapOperationProvider operationProvider
protected final MapServiceContext mapServiceContext
public TransactionalMapProxySupport(String name, MapService mapService, NodeEngine nodeEngine, Transaction transaction)
protected void checkTransactionState()
public boolean containsKeyInternal(Data key)
public int sizeInternal()
public boolean replaceIfSameInternal(Data key, Object oldValue, Data newValue)
protected long getTimeInMillis(long time, TimeUnit timeunit)
public String getName()
DistributedObject
getName
in interface DistributedObject
public final String getServiceName()
DistributedObject
getServiceName
in interface DistributedObject
getServiceName
in class AbstractDistributedObject<MapService>
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.