accumulator

2熱度

1回答

我遇到一個問題，即Spark上的Accumulator不能是GC。 def newIteration (lastParams: Accumulable[Params, (Int, Int, Int)], lastChosens: RDD[Document], i: Int): Params = { if (i == maxIteration) return lastParam

0熱度

2回答

將大於或小於檢查應用於字符串和基元數據類型？

我正在研究一個項目，該項目要求我爲累積器創建一個模板類，以返回天氣或不是傳遞給它的列表。訂單正在上升。我得太多可能的問題，但我似乎無法弄清楚如何做一個大於/小於檢查兩個基本數據類型和字符串。我將澄清：進程如下所示：聲明瞭一個列表/向量，並在其中存儲了內容。然後調用一個名爲apply的輔助累加器。此累加器（應用）遍歷列表中每個值調用InOrder累加器的.put（）方法的列表。值可以是do

-1熱度

2回答

如何使用蓄電池

知識庫走出一個無限循環的序言中我使用： connected(1,2). connected(3,4). connected(5,6). connected(7,8). connected(9,10). connected(12,13). connected(13,14). connected(15,16). connected(17,18). connected(19,20).

8熱度

2回答

星火輸球println（）一樣在stdout

我有以下代碼： val blueCount = sc.accumulator[Long](0) val output = input.map { data => for (value <- data.getValues()) { if (record.getEnum() == DataEnum.BLUE) { blueCount += 1 printl

1熱度

2回答

累加器在Simulink

我有一個MATLAB函數塊在Simulink並且用於每個步驟simlulink並不欲輸入與增量1 實施例的計數器：第1步 - >度Acc = 1 第2步 - >度Acc = 2 我嘗試使用計數塊+脈衝發生器，但simulink的時間步長不是恆定的。任何想法？

3熱度

1回答

Spark accumulableCollection不能與mutable配合使用

我正在使用Spark來完成員工記錄積累，並且使用了Spark的累加器。我使用Map [empId，emp]作爲accumulableCollection，以便我可以通過他們的ID搜索員工。我嘗試了一切，但它不起作用。有人指出，如果我使用accumulableCollection的方式有任何邏輯問題，或者不支持Map。下面是我的代碼 package demo import org.apache.

2熱度

2回答

如何顯示DStream中更新的當前累加器值？

我正在處理一個Java jar。累加器累加流值。問題是，我想在每次增加或在特定的時間間隔內在UI中顯示值。但是，由於累加器值只能從驅動程序中獲取，所以我無法訪問該值直到該過程完成其執行。關於如何定期訪問此值的任何想法？我的代碼如下 package com.spark; import java.util.HashMap; import java.util.Map; import org

1熱度

1回答

總集到超

鑑於MongoDB的以下數據： [ { id: 1, stuff: ["A", "B"] }, { id: 2, stuff: ["B", "C"] }, ... (lots and lots of records) ] 是否有可能獲得的所有「東西」集合的並集？例如["A","B","C"] 我使用$addToSet aggregate([ { $gr

1熱度

1回答

從accumulator_set中刪除或修改accumulators ::標記

在boost中，是否可以從accumulator_set動態地刪除給定的boost::accumulators::tag？ typedef boost::accumulators::features < boost::accumulators::tag::count, boost::accumulators::tag::max, boost::accumulators

0熱度

5回答

如何在java中累積值？

現在，我正在學習所有關於類，構造函數和實例的知識。我在java中做了一小段代碼，並且被這個特定代碼困住了。 ***我的代碼輸出被假設是這樣的：輸出輸入金額：500 你想再次進入量（Y/N）：Y 輸入量：45 你想再次進入量（Y/N）：N 總計：545 ***，而是我的輸出是這樣的：輸出輸入金額：500 你想再次進入量（Y/N）： Ÿ 輸入量：45 你想再次進入量（Y/N）：N 總計：45