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")