metrics

2热度

2回答

什么是从MongoDB读取批量数据的有效方式（版本> = 3.2）。我只为Bulk write找到方法。我正在创建指标，分析存储在mongoDB中的数据。由于我正在测试水域，因此我的技术栈仅限于Mongo Aggregation Pipeline和Java。

3热度

1回答

星火流处理时间与总延时VS处理延迟

我想了解什么火花流输出不同指标的含义，我稍微困惑是什么处理时间之间的差异，总延时和处理最后一批延迟？我已经看过星火流指南，其中提到了处理时间为搞清楚一个关键指标，如果系统已经落后，但其他地方，如“临星火流：实时分析的禅使用Apache Spark“谈论使用总延迟和处理延迟。我没有找到任何文档列出了Spark Streaming生成的所有指标，并解释了它们各自的含义。如果有人能够概述这三个指标中

0热度

1回答

卡夫卡生产者和消费者信息

我想创建一个工具，可以随机杀死卡夫卡生产者和消费者，以模拟生产环境。有没有办法找到卡夫卡集群中活跃的生产者和消费者？我想确切地知道哪个主机在哪个主机作为生产者或消费者？

1热度

2回答

弹簧执行器自定义指标（平均，最小，最大响应时间）

有没有一种方法可以生成每个请求的平均响应时间，每个请求的最小响应时间和每个请求的最大响应时间？我想我可以使用Atomic变量或每个请求的同步来避免竞争条件，但我不确定这是否是最好的方法。

0热度

1回答

火花管道评估

如何获得评估者在火花管道中的结果？ val evaluator = new BinaryClassificationEvaluator() val cv = new CrossValidator() .setEstimator(pipeline) .setEvaluator(evaluator) .setEstimatorParamMaps(paramGrid)

3热度

1回答

无法在eclipse neon中安装公制插件1

我在ubuntu 14.04上使用eclipse neon.1，我想安装公制插件，它一直说“无法完成配置操作，请更改您的选择并重试详情见下文。“ 详细信息：无法完成安装，因为找不到一个或多个必需的项目。正在安装的软件：指标特征3.14.1.201104282140（com.stateofflow.eclipse.metrics.feature.group 3.14.1.201104282140

2热度

1回答

Jolokia Spark度量

需要将jolokia代理连接到我的spark工作并查看sinc指标。 https://jolokia.org/reference/html/agents.html#jvm-agent 可用的两个选项中，不能使用javaagent的spark-submit和on the fly方法是棘手的，因为不知道哪个worker节点和哪个pid代理启动。如何在我的代码中启动jolokia。 Spark代码是用

0热度

1回答

kibana v4如何可视化度量指标

我正在使用com.codahale.metrics提供弹性索引度量。我有几个米（指标类型米）与字段名称不同。我想在计数栏上每米有一张图。其实，我只有全部计数的全部计数。我是新的kibana所以也许这很容易想象;-)

2热度

3回答

如何重置dropwizard指标的计时器？

我们正在处理定期进入的消息。我们使用codahale dropwizard度量''Timer'来测量处理它们所花费的时间。我发现有人有同样的问题here： “与指数衰减水库的问题是，如果没有新的数据进来，这将继续给予同样的号码所有的时间。例如，让我们说你更新计时器与5和7（然后不放任何东西），然后无论你什么时候看到（甚至在x小时后），定时器仍然会显示平均值为6，这不代表最后5分钟的任何方式所以

0热度

2回答

psutil的cpu_percent总是返回0.0

我想我的瓶的应用程序来报告它当前正在使用的百分比有多少CPU和内存： import psutil from flask import Flask, request, jsonify app = Flask(__name__) @app.route("/test", methods=["GET"]) def healthz(): return jsonify(msg="OK")