热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

com.hazelcast.config.MapConfig.isStatisticsEnabled()方法的使用及代码示例

本文整理了Java中com.hazelcast.config.MapConfig.isStatisticsEnabled()方法的一些代码示例,展示了MapConfig.isStatisticsEna

本文整理了Java中com.hazelcast.config.MapConfig.isStatisticsEnabled()方法的一些代码示例,展示了MapConfig.isStatisticsEnabled()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。MapConfig.isStatisticsEnabled()方法的具体详情如下:
包路径:com.hazelcast.config.MapConfig
类名称:MapConfig
方法名:isStatisticsEnabled

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();
}
}

推荐阅读
author-avatar
MC_炽焰
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有