java metrics 简书_flink Metrics及其使用-程序员宅基地

技术标签： java metrics 简书

flink metric用来对外暴露系统内部的一些运行指标，比如flink框架运行时的JVM相关配置，或者基于flink开发的项目。

监控类型

flink提供了Counter, Gauge, Histogram and Meter四种类型的指标。我们通过继承RichFunction拿到MetricGroup，并向其中填充指标。

Counter：

用与存储数值类型，比如统计数据输入、输出总数量。

public class MyMapper extends RichMapFunction {

private transient Counter counter;

@Override

public void open(Configuration config) {

this.counter = getRuntimeContext()

.getMetricGroup()

.counter("myCounter");

}

@Override

public String map(String value) throws Exception {

this.counter.inc();

return value;

}

Gauge:

可以用来存储任何类型，前提要实现org.apache.flink.metrics.Gauge接口，重写getValue方法，如果返回类型为Object则该类需要重写toString方法。

有些场景下，需要根据业务计算出指标，则Gauge使用起来更灵活。

public class MyMapper extends RichMapFunction {

private transient int valueToExpose = 0;

@Override

public void open(Configuration config) {

getRuntimeContext()

.getMetricGroup()

.gauge("MyGauge", new Gauge() {

@Override

public Integer getValue() {

return valueToExpose;

}

});

}

@Override

public String map(String value) throws Exception {

valueToExpose++;

return value;

}

Meter：

用来计算平均速率，直接使用其子类MeterView更方便一些。

public class MyMapper extends RichMapFunction {

private transient Counter numInBytes;

private transient Meter meter;

@Override

public void open(Configuration config) {

this.meter = getRuntimeContext()

.getMetricGroup()

.meter("myMeter", new MeterView(numInBytes, 20))

本文链接：https://blog.csdn.net/weixin_33293612/article/details/114850563

原作者删帖不实内容删帖广告或垃圾文章投诉

智能推荐

常用的原型开发工具-程序员宅基地

文章浏览阅读67次。1、Axure RP（Rapid Prototyping）Axure（读音为Ack-Sure）无疑是目前最受关注的原型开发工具，其能通过组件的方式帮助网站或软件设计师快速建立带有注释的原型（流程图、线框图），并凭借自定义可重用的元件、动态面板以及丰富的script能够建立基本功能或页面逻辑的动态演示文件。Axure借鉴了office的界面，能够让用户快速上手，并且提供了..._程序员原型法常用工具

nuiapp请求网络_uni-app 接口 - 网络请求-程序员宅基地

文章浏览阅读145次。1、 uni.request(OBJECT) 发起网络请求参数名类型必填默认值说明url String 是开发者服务器接口地址data Object/String/ArrayBuffer 否请求的参数header Object 否设置请求的 header，header 中不能设置 Referer。method String 否 GET (需大写)有效值：OPTIONS, GET...

Vim命令学习参考_hadoop vim是什么操作-程序员宅基地

文章浏览阅读368次。1. 关于Vim1.1 Vim的几种模式2. 启动Vim3. 文档操作4. 光标的移动4.1 基本移动4.2 翻屏4.3 标记5. 插入文本5.1 基本插入5.2 改写插入6. 剪切复制和寄存器6.1 剪切和复制、粘贴6.2 文本对象6.3 寄存器7. 查找与替换7.1 查找7.2 替换7.3 正则表达式8. 排版8.1 基本排版8..._hadoop vim是什么操作

应用加速，数字人民币接入多地交通出行场景 | 产业区块链发展周报-程序员宅基地

文章浏览阅读3.1k次。摘要产业动态：微众银行多方大数据隐私计算平台通过信通院权威评测欧洲最大移动运营商沃达丰将为AI智能协议移动终端提供移动通信服务汇丰银行加入迪拜经济的阿联酋KYC区块链平台重庆市先进区块链研..._交通联合小额支付

大数据毕设分享(含算法) 机器学习二手房价格预测及可视化系统（源码+论文）_数据挖掘二手房价预测-程序员宅基地

文章浏览阅读850次，点赞23次，收藏24次。通过整个项目的实践，我们亲身体会了数据挖掘的那张路线图，预处理、分析之后发现问题（Knowledge），再进行新的处理，再重新分析挖掘，做评估，然后发现新的问题，再从头开始，在这几个过程的循环往复中完成了整个项目。_数据挖掘二手房价预测

input框下面紧跟着div弹出层，js取top left数值[实例]_input触发弹出层-程序员宅基地

文章浏览阅读3.6k次。var setSearchFlag; function showSearch(obj){ clearSearchFlag(); var w3c=(document.getElementById)? true:false;//w3c 标准 var ns6=(w3c && (navigator.appName=="Netscape"))? true: false;//Netsca_input触发弹出层