本文整理了Java中com.hazelcast.config.MapConfig.isStatisticsEnabled()
方法的一些代码示例,展示了MapConfig.isStatisticsEnabled()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MapConfig.isStatisticsEnabled()
方法的具体详情如下:
包路径:com.hazelcast.config.MapConfig
类名称:MapConfig
方法名:isStatisticsEnabled
[英]Checks if statistics are enabled for this map.
[中]
代码示例来源:origin: com.hazelcast/hazelcast-all
public DataRecordFactory(MapConfig config, SerializationService serializationService,
PartitioningStrategy partitionStrategy) {
this.serializatiOnService= serializationService;
this.partitiOnStrategy= partitionStrategy;
this.statisticsEnabled = config.isStatisticsEnabled();
this.cacheDeserializedValues = config.getCacheDeserializedValues();
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public LocalMapStats getLocalMapStats() {
if (!mapConfig.isStatisticsEnabled()) {
return EMPTY_LOCAL_MAP_STATS;
}
return mapServiceContext.getLocalMapStatsProvider().createLocalMapStats(name);
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public LocalMapStats getLocalMapStats() {
if (!mapConfig.isStatisticsEnabled()) {
return EMPTY_LOCAL_MAP_STATS;
}
return mapServiceContext.getLocalMapStatsProvider().createLocalMapStats(name);
}
代码示例来源:origin: com.hazelcast/hazelcast-all
private void updateStatistics(MapContainer mapContainer) {
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
LocalMapStatsImpl localStats = localMapStatsProvider.getLocalMapStatsImpl(mapContainer.getName());
localStats.incrementOtherOperations();
}
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
protected void beforeResponse() {
final long latencyNanos = System.nanoTime() - startTimeNanos;
final MapService mapService = getService(MapService.SERVICE_NAME);
MapContainer mapCOntainer= mapService.getMapServiceContext().getMapContainer(parameters.name);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapService.getMapServiceContext().getLocalMapStatsProvider().getLocalMapStatsImpl(parameters.name)
.incrementPutLatencyNanos(parameters.entries.size(), latencyNanos);
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
protected void beforeResponse() {
final long latencyNanos = System.nanoTime() - startTimeNanos;
final MapService mapService = getService(MapService.SERVICE_NAME);
MapContainer mapCOntainer= mapService.getMapServiceContext().getMapContainer(parameters.name);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapService.getMapServiceContext().getLocalMapStatsProvider().getLocalMapStatsImpl(parameters.name)
.incrementGetLatencyNanos(parameters.keys.size(), latencyNanos);
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
private void incrementEventStatsInternal(String mapName) {
MapContainer mapCOntainer= mapServiceContext.getMapContainer(mapName);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapServiceContext.getLocalMapStatsProvider()
.getLocalMapStatsImpl(mapName).incrementReceivedEvents();
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
private void incrementEventStatsInternal(String mapName) {
MapContainer mapCOntainer= mapServiceContext.getMapContainer(mapName);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapServiceContext.getLocalMapStatsProvider()
.getLocalMapStatsImpl(mapName).incrementReceivedEvents();
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
public void run() {
empty = recordStore.isEmpty();
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
LocalMapStatsImpl localMapStatsImpl = mapServiceContext.getLocalMapStatsProvider()
.getLocalMapStatsImpl(name);
localMapStatsImpl.incrementOtherOperations();
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
public void run() {
empty = recordStore.isEmpty();
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
LocalMapStatsImpl localMapStatsImpl = mapServiceContext.getLocalMapStatsProvider()
.getLocalMapStatsImpl(name);
localMapStatsImpl.incrementOtherOperations();
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public void run() {
cOntains= recordStore.containsValue(testValue);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
LocalMapStatsProvider localMapStatsProvider = mapServiceContext.getLocalMapStatsProvider();
localMapStatsProvider.getLocalMapStatsImpl(name).incrementOtherOperations();
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void run() {
cOntains= recordStore.containsValue(testValue);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
LocalMapStatsProvider localMapStatsProvider = mapServiceContext.getLocalMapStatsProvider();
localMapStatsProvider.getLocalMapStatsImpl(name).incrementOtherOperations();
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
protected void beforeResponse() {
final long latencyNanos = System.nanoTime() - startTimeNanos;
final MapService mapService = getService(MapService.SERVICE_NAME);
MapContainer mapCOntainer= mapService.getMapServiceContext().getMapContainer(parameters.name);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapService.getMapServiceContext().getLocalMapStatsProvider().getLocalMapStatsImpl(parameters.name)
.incrementRemoveLatencyNanos(latencyNanos);
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
protected void beforeResponse() {
final long latencyNanos = System.nanoTime() - startTimeNanos;
final MapService mapService = getService(MapService.SERVICE_NAME);
MapContainer mapCOntainer= mapService.getMapServiceContext().getMapContainer(parameters.name);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapService.getMapServiceContext().getLocalMapStatsProvider().getLocalMapStatsImpl(parameters.name)
.incrementGetLatencyNanos(latencyNanos);
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
protected void beforeResponse() {
final long latencyNanos = System.nanoTime() - startTimeNanos;
final MapService mapService = getService(MapService.SERVICE_NAME);
MapContainer mapCOntainer= mapService.getMapServiceContext().getMapContainer(parameters.name);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapService.getMapServiceContext().getLocalMapStatsProvider().getLocalMapStatsImpl(parameters.name)
.incrementRemoveLatencyNanos(latencyNanos);
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
public void run() {
recordStore.checkIfLoaded();
size = recordStore.size();
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
LocalMapStatsProvider localMapStatsProvider = mapServiceContext.getLocalMapStatsProvider();
LocalMapStatsImpl localMapStatsImpl = localMapStatsProvider.getLocalMapStatsImpl(name);
localMapStatsImpl.incrementOtherOperations();
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
public void run() {
recordStore.checkIfLoaded();
size = recordStore.size();
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
LocalMapStatsProvider localMapStatsProvider = mapServiceContext.getLocalMapStatsProvider();
LocalMapStatsImpl localMapStatsImpl = localMapStatsProvider.getLocalMapStatsImpl(name);
localMapStatsImpl.incrementOtherOperations();
}
}
代码示例来源:origin: com.hazelcast/hazelcast-all
@Override
protected void beforeResponse() {
final long latencyNanos = System.nanoTime() - startTimeNanos;
final MapService mapService = getService(MapService.SERVICE_NAME);
MapContainer mapCOntainer= mapService.getMapServiceContext().getMapContainer(getDistributedObjectName());
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapService.getMapServiceContext().getLocalMapStatsProvider().getLocalMapStatsImpl(getDistributedObjectName())
.incrementPutLatencyNanos(latencyNanos);
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
protected void beforeResponse() {
final long latencyNanos = System.nanoTime() - startTimeNanos;
final MapService mapService = getService(MapService.SERVICE_NAME);
MapContainer mapCOntainer= mapService.getMapServiceContext().getMapContainer(getDistributedObjectName());
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
mapService.getMapServiceContext().getLocalMapStatsProvider().getLocalMapStatsImpl(getDistributedObjectName())
.incrementPutLatencyNanos(latencyNanos);
}
}
代码示例来源:origin: hazelcast/hazelcast-jet
@Override
protected void afterResponse() {
final MapService mapService = getService(MapService.SERVICE_NAME);
MapContainer mapCOntainer= mapService.getMapServiceContext().getMapContainer(parameters.name);
if (mapContainer.getMapConfig().isStatisticsEnabled()) {
LocalMapStatsProvider localMapStatsProvider = mapService.getMapServiceContext().getLocalMapStatsProvider();
localMapStatsProvider.getLocalMapStatsImpl(parameters.name).incrementOtherOperations();
}
}