storm中有时需要添加一些metrics监控项,这时需要添加metrics.
在spout或者bolt的prepare方法中注册metrics
public void prepare(@SuppressWarnings("rawtypes") Map stormConf,
TopologyContext context, OutputCollector collector) {
this.collector = collector;
barMetric = new CountMetric();
context.registerMetric("bar", this.barMetric, 3);
}
在恰当的时候更新metrics
public void execute(Tuple input) {
if (input.getSourceComponent().equals("bar")) {
barMetric.incr();
}
collector.ack(input);
}
启动拓扑的时候注册metrics的consumer
conf.registerMetricsConsumer(MetricsConsumer.class);
分享到:
相关推荐
风暴指标报告者 一个Storm指标报告器,能够将Storm内置指标和自定义指标... 上面的屏幕截图是使用自定义StormMetricProcessor实现生成的,而不是源代码中包含的实现。 它描述了一种特定的Graphite命名约定(例如,主机
#storm-graphite-metrics Apache Storm 的度量消费者,它使用 Storm 的度量消费者接口将度量从 Storm 导出到石墨中。 ##Usage 在 Storm 配置中 conf . registerMetricsConsumer( GraphiteMetricsConsumer . class,...
在keras的loss库中添加rmse方法,成功使模型能正常使用rmse方法。在metrics.py文件上添加rmse方法后可以使用model.compile(loss='mse',weighted_metrics=['rmse'])方法,可以在其他loss的条件下观测rmse的变化
这是与ApacheSpark指标相关的自定义类(例如源,接收器)的存储库。 我们试图用Prometheus接收器扩展Spark Metrics子系统,但没有在上游合并。 为了支持其他人使用Prometheus,我们将接收器外部化并通过此存储库提供...
赠送jar包:metrics-jvm-3.1.5.jar; 赠送原API文档:metrics-jvm-3.1.5-javadoc.jar; 赠送源代码:metrics-jvm-3.1.5-sources.jar;...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
赠送jar包:metrics-core-4.2.7.jar; 赠送原API文档:metrics-core-4.2.7-javadoc.jar; 赠送源代码:metrics-core-4.2.7-sources.jar;...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
赠送jar包:metrics-graphite-3.1.5.jar; 赠送原API文档:metrics-graphite-3.1.5-javadoc.jar; 赠送源代码:metrics-graphite-3.1.5-...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
dropwizard metrics
yammer metrics-2.2.0 源码 yammer metrics-2.2.0 源码 yammer metrics-2.2.0 源码 yammer metrics-2.2.0 源码
赠送jar包:flink-metrics-core-1.7.1.jar 赠送原API文档:flink-metrics-core-1.7.1-javadoc.jar 赠送源代码:flink-metrics-core-...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
赠送jar包:metrics-core-3.1.5.jar; 赠送原API文档:metrics-core-3.1.5-javadoc.jar; 赠送源代码:metrics-core-3.1.5-sources.jar;...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
赠送jar包:flink-metrics-core-1.14.3.jar; 赠送原API文档:flink-metrics-core-1.14.3-javadoc.jar; 赠送源代码:flink-metrics-core...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
赠送jar包:hbase-metrics-1.4.3.jar; 赠送原API文档:hbase-metrics-1.4.3-javadoc.jar; 赠送源代码:hbase-metrics-1.4.3-sources....人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
docker load -i kube-state-metrics-v2.4.2.tar.gz docker images|grep k8s.gcr.io/kube-state-metrics/kube-state-metrics
java运行依赖jar包
赠送jar包:flink-metrics-core-1.10.0.jar; 赠送原API文档:flink-metrics-core-1.10.0-javadoc.jar; 赠送源代码:flink-metrics-core...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
赠送jar包:flink-metrics-core-1.7.1.jar 赠送原API文档:flink-metrics-core-1.7.1-javadoc.jar ...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。 双语对照,边学技术、边学英语。
team which metrics it can use to objectively measure performance. You'll learn what data really counts, along with where to find it, how to get it, and how to analyze it. Because meaningful data may ...
赠送jar包:metrics-core-3.1.2.jar; 赠送原API文档:metrics-core-3.1.2-javadoc.jar; 赠送源代码:metrics-core-3.1.2-sources.jar;...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。
赠送jar包:metrics-core-2.2.0.jar; 赠送原API文档:metrics-core-2.2.0-javadoc.jar;...人性化翻译,文档中的代码和结构保持不变,注释和说明精准翻译,请放心使用。 双语对照,边学技术、边学英语。