public class CMap extends Object
Modifier and Type | Class and Description |
---|---|
static class |
CMap.CMapEntry |
Modifier and Type | Method and Description |
---|---|
boolean |
add(Request req,
boolean backup) |
void |
addIndex(Expression expression,
boolean ordered,
int attributeIndex) |
void |
addListener(Data key,
Address address,
boolean includeValue) |
void |
appendState(StringBuffer sbState) |
boolean |
backup(Request req) |
void |
collectScheduledLocks(Map<Object,DistributedLock> lockOwners,
Map<Object,DistributedLock> lockRequested)
for dead-lock detection
TODO: Warning => DistributedLock is not thread-safe !!!
|
boolean |
containsKey(Request req) |
void |
doBackup(Request req) |
Data |
get(Request req) |
int |
getAsyncBackupCount() |
int |
getBackupCount() |
Object |
getInitLock() |
Collection<Record> |
getLockedRecordsFor(long acquiredAtLeastFor)
Thread-safe
|
MapConfig |
getMapConfig() |
CMap.CMapEntry |
getMapEntry(Request req) |
MapIndexService |
getMapIndexService() |
MapLoader |
getMapLoader() |
String |
getName() |
Node |
getNode() |
Record |
getRecord(Data key) |
MapConfig |
getRuntimeConfig() |
int |
getTotalBackupCount() |
void |
incrementGetCount() |
boolean |
isCacheValue() |
boolean |
isClearQuick() |
boolean |
isList() |
boolean |
isMap() |
boolean |
isMultiMap() |
boolean |
isReadBackupData() |
boolean |
isSet() |
void |
lockMap(Request request) |
void |
onDisconnect(Address deadAddress) |
void |
onDisconnect(Record record,
Address deadAddress) |
void |
onMigrate(Record record) |
void |
onRemoveMulti(Request req,
Record record) |
void |
own(DataRecordEntry dataRecordEntry) |
void |
put(Request req) |
void |
putMulti(Request req) |
void |
remove(Request req) |
boolean |
removeItem(Request req) |
void |
removeListener(Data key,
Address address) |
void |
setRuntimeConfig(MapConfig mapConfig) |
int |
size() |
int |
size(int expectedPartitionVersion) |
void |
storeAsBackup(DataRecordEntry dataRecordEntry) |
String |
toString() |
int |
valueCount(Data key) |
public void setRuntimeConfig(MapConfig mapConfig)
public MapConfig getRuntimeConfig()
public MapLoader getMapLoader()
public Object getInitLock()
public void lockMap(Request request)
public void addIndex(Expression expression, boolean ordered, int attributeIndex)
public int getBackupCount()
public int getAsyncBackupCount()
public int getTotalBackupCount()
public boolean isCacheValue()
public boolean isClearQuick()
public boolean isReadBackupData()
public void own(DataRecordEntry dataRecordEntry)
public void storeAsBackup(DataRecordEntry dataRecordEntry)
public boolean isMultiMap()
public boolean isSet()
public boolean isList()
public boolean isMap()
public boolean backup(Request req)
public void doBackup(Request req)
public boolean containsKey(Request req)
public CMap.CMapEntry getMapEntry(Request req)
public boolean add(Request req, boolean backup)
public void onMigrate(Record record)
public void onDisconnect(Address deadAddress)
public void putMulti(Request req)
public void put(Request req)
public int size()
public int size(int expectedPartitionVersion)
public Collection<Record> getLockedRecordsFor(long acquiredAtLeastFor)
acquiredAtLeastFor
- min acquire period of lock in mspublic void collectScheduledLocks(Map<Object,DistributedLock> lockOwners, Map<Object,DistributedLock> lockRequested)
lockOwners
- lockRequested
- public int valueCount(Data key)
public void incrementGetCount()
public boolean removeItem(Request req)
public void remove(Request req)
public void appendState(StringBuffer sbState)
public MapConfig getMapConfig()
public Node getNode()
public MapIndexService getMapIndexService()
public String getName()
Copyright © 2013 Hazelcast, Inc.. All rights reserved.