public class ConcurrentMapManager extends BaseManager
Modifier and Type | Class and Description |
---|---|
class |
ConcurrentMapManager.MClearQuick |
class |
ConcurrentMapManager.MContainsValue |
class |
ConcurrentMapManager.MEmpty |
class |
ConcurrentMapManager.MLockMap |
BaseManager.ConnectionAwareOp, BaseManager.ResponseQueueCall, BaseManager.ResponsiveOperationHandler, BaseManager.ReturnResponseProcess, BaseManager.TargetAwareOp
BATCH_OPS_EXECUTOR_NAME, dataMemberCount, INTERNAL_OPS_EXECUTOR_NAME, localIdGen, logger, lsMembers, mapCalls, mapMembers, maxOperationLimit, maxOperationTimeout, node, qServiceThreadPacketCache, redoGiveUpThreshold, redoLogThreshold, redoWaitMillis, responsePollTimeout, systemLogService, thisAddress, thisMember
addRemoteCall, checkServiceThread, createRemotelyProcessablePacket, createSimpleMapEntry, enqueueAndReturn, enqueueAndWait, enqueueAndWait, getInstanceType, getMasterAddress, getMembers, getNextMemberAfter, getNextMemberAfter, getNode, getPacketProcessor, getRemoteCall, getThisAddress, handleInterruptedException, handleResponse, isActive, isLiteMember, isMaster, logRedo, obtainPacket, obtainPacket, registerPacketProcessor, releasePacket, removeRemoteCall, rethrowException, returnRedoResponse, returnResponse, returnResponse, send, send, sendEvents, sendOrReleasePacket, sendOrReleasePacket, sendProcessableTo, sendProcessableTo, sendProcessableToAll, sendResponse, sendResponse, sendResponseFailure
public PartitionManager getPartitionManager()
public void addWanMergeListener(WanMergeListener listener)
public void removeWanMergeListener(WanMergeListener listener)
public void onRestart()
public void reset()
public void shutdown()
public void flush(String name)
public void syncForDead(MemberImpl deadMember)
public void syncForAdd()
public void mergeWanRecord(DataRecordEntry mergingEntry)
mergingEntry
- public int getPartitionCount()
public PartitionInfo getPartitionInfo(int partitionId)
public void startCleanup(boolean now, boolean force)
public void executeCleanup(CMap cmap, boolean force)
public void destroy(String name)
protected Address getBackupMember(int partitionId, int replicaIndex)
public LocalMapStatsImpl getLocalMapStats(String name)
public Address getPartitionOwner(int partitionId)
public boolean isMigrating(Request req)
public boolean isMigrating(Request req, int replica)
isMigrating
in class BaseManager
public int getPartitionId(Request req)
public final int getPartitionId(Data key)
public long newRecordId()
public Pairs queryMap(CMap cmap, ClusterOperation operation, Predicate predicate) throws QueryException
QueryException
Copyright © 2013 Hazelcast, Inc.. All rights reserved.