com.hazelcast.map.impl

Class LocalMapStatsProvider

java.lang.Object

com.hazelcast.map.impl.LocalMapStatsProvider

public class LocalMapStatsProvider
extends Object

Provides node local statistics of a map via createLocalMapStats(java.lang.String) and also holds all LocalMapStatsImpl implementations of all maps.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	LocalMapStatsProvider.LocalMapOnDemandCalculatedStats

Field Summary

Fields

Modifier and Type	Field and Description
protected ClusterService	clusterService
protected ConstructorFunction<String,LocalMapStatsImpl>	constructorFunction
protected ILogger	logger
protected MapServiceContext	mapServiceContext
protected NearCacheProvider	nearCacheProvider
protected InternalPartitionService	partitionService
protected static int	RETRY_COUNT
protected ConcurrentMap<String,LocalMapStatsImpl>	statsMap
protected static int	WAIT_PARTITION_TABLE_UPDATE_MILLIS

Constructor Summary

Constructors

Constructor and Description
LocalMapStatsProvider(MapServiceContext mapServiceContext)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addNearCacheStats(LocalMapStatsImpl stats, LocalMapStatsProvider.LocalMapOnDemandCalculatedStats onDemandStats, MapContainer mapContainer) Adds near cache stats.
protected void	addOwnerPartitionStats(LocalMapStatsImpl stats, LocalMapStatsProvider.LocalMapOnDemandCalculatedStats onDemandStats, String mapName, int partitionId) Calculates and adds owner partition stats.
protected void	addReplicaPartitionStats(LocalMapStatsProvider.LocalMapOnDemandCalculatedStats onDemandStats, String mapName, int partitionId, InternalPartition partition, InternalPartitionService partitionService, int backupCount, Address thisAddress) Calculates and adds replica partition stats.
LocalMapStatsImpl	createLocalMapStats(String mapName)
void	destroyLocalMapStatsImpl(String name)
protected long	getHits(Record record)
LocalMapStatsImpl	getLocalMapStatsImpl(String name)
protected RecordStore	getRecordStoreOrNull(String mapName, int partitionId)
protected Address	getReplicaAddress(int replica, InternalPartition partition, InternalPartitionService partitionService, int backupCount) Gets replica address.
protected boolean	hasRecords(RecordStore recordStore)
protected int	isLocked(Data key, RecordStore recordStore) Return 1 if locked, otherwise 0.
protected boolean	isReplicaAvailable(Address replicaAddress, InternalPartitionService partitionService, int backupCount)
protected boolean	isReplicaOnThisNode(Address replicaAddress, Address thisAddress)
protected void	printWarning(InternalPartition partition, int replica)
protected void	sleep()
protected Address	waitForReplicaAddress(int replica, InternalPartition partition, InternalPartitionService partitionService, int backupCount) Waits partition table update to get replica address if current replica address is null.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

WAIT_PARTITION_TABLE_UPDATE_MILLIS

protected static final int WAIT_PARTITION_TABLE_UPDATE_MILLIS

See Also:

Constant Field Values

RETRY_COUNT

protected static final int RETRY_COUNT

See Also:

Constant Field Values

statsMap

protected final ConcurrentMap<String,LocalMapStatsImpl> statsMap

constructorFunction

protected final ConstructorFunction<String,LocalMapStatsImpl> constructorFunction

mapServiceContext

protected final MapServiceContext mapServiceContext

nearCacheProvider

protected final NearCacheProvider nearCacheProvider

clusterService

protected final ClusterService clusterService

partitionService

protected final InternalPartitionService partitionService

logger

protected final ILogger logger

Constructor Detail

LocalMapStatsProvider

public LocalMapStatsProvider(MapServiceContext mapServiceContext)

Method Detail

getLocalMapStatsImpl

public LocalMapStatsImpl getLocalMapStatsImpl(String name)

destroyLocalMapStatsImpl

public void destroyLocalMapStatsImpl(String name)

createLocalMapStats

public LocalMapStatsImpl createLocalMapStats(String mapName)

addOwnerPartitionStats

protected void addOwnerPartitionStats(LocalMapStatsImpl stats,
                          LocalMapStatsProvider.LocalMapOnDemandCalculatedStats onDemandStats,
                          String mapName,
                          int partitionId)

Calculates and adds owner partition stats.

getHits

protected long getHits(Record record)

isLocked

protected int isLocked(Data key,
           RecordStore recordStore)

Return 1 if locked, otherwise 0. Used to find LocalMapStatsImpl.lockedEntryCount.

addReplicaPartitionStats

protected void addReplicaPartitionStats(LocalMapStatsProvider.LocalMapOnDemandCalculatedStats onDemandStats,
                            String mapName,
                            int partitionId,
                            InternalPartition partition,
                            InternalPartitionService partitionService,
                            int backupCount,
                            Address thisAddress)

Calculates and adds replica partition stats.

hasRecords

protected boolean hasRecords(RecordStore recordStore)

isReplicaAvailable

protected boolean isReplicaAvailable(Address replicaAddress,
                         InternalPartitionService partitionService,
                         int backupCount)

isReplicaOnThisNode

protected boolean isReplicaOnThisNode(Address replicaAddress,
                          Address thisAddress)

printWarning

protected void printWarning(InternalPartition partition,
                int replica)

getRecordStoreOrNull

protected RecordStore getRecordStoreOrNull(String mapName,
                               int partitionId)

getReplicaAddress

protected Address getReplicaAddress(int replica,
                        InternalPartition partition,
                        InternalPartitionService partitionService,
                        int backupCount)

Gets replica address. Waits if necessary.

See Also:

waitForReplicaAddress(int, com.hazelcast.partition.InternalPartition, com.hazelcast.partition.InternalPartitionService, int)

waitForReplicaAddress

protected Address waitForReplicaAddress(int replica,
                            InternalPartition partition,
                            InternalPartitionService partitionService,
                            int backupCount)

Waits partition table update to get replica address if current replica address is null.

sleep

protected void sleep()

addNearCacheStats

protected void addNearCacheStats(LocalMapStatsImpl stats,
                     LocalMapStatsProvider.LocalMapOnDemandCalculatedStats onDemandStats,
                     MapContainer mapContainer)

Adds near cache stats.