accumulator

2熱

1答えて

私のアキュムレータがSparkによって正しく更新されなかった理由がわかりません。 object AccumulatorsExample extends App { val acc = sc.accumulator(0L, "acc") sc range(0, 20000, step = 25) map { _ => acc += 1 } count() assert(

1熱

2答えて

カスタムアキュムレータを作成する方法、つまりSet [String]？

Apache Accarkでカスタムアキュムレータを使用して、セットに蓄積しようとしています。結果にはSet [String]型が必要です。私はこのカスタムのアキュムレータを作成します： object SetAccumulatorParam extends AccumulatorParam[Set[String]] { def addInPlace(r1: mutable.Set[Str

2熱

1答えて

Sparkのアキュムレータを関数に渡すにはどうしたらいいですか？

私はこのようなことをしたい。 val ac = sc.accumulator(0) .... a = a.map(x => someFunction(x, the_accumulator_object)) .... 上記のコードには、the_accumulator_ojbectの代わりになるものはありますか？文章はacでいいですか？また、機能に def someFunction(x:

0熱

2答えて

Pythonでforループ範囲でアキュムレータを使用するにはどうすればよいですか？

私はPythonでアキュムレータを使用しようとしていますが、動作させることができません。私は人口を2から始め、percentIncrease入力で増加させたいが、それは正しく出てこない。私は間違って何をしていますか？私はそれがどのように蓄積しているのか知っていますが、私が試みたすべての試みは失敗しました。 #Get the starting number of organisms startin

0熱

2答えて

ユーザ定義関数を使用してC++でアキュムレータを作成するにはどうすればよいですか？

私は一杯のコーヒーを売り続けようとしています。私はそれを行うためにユーザー定義関数を使用しなければなりません。添付されたコードのさまざまなバリエーションを試しましたが、何も動作していないようです。私は間違って何をしていますか？また、私はC++のnewbですので、それが素人に見えます！ #include <iostream> #include <iomanip> #include <fstrea

6熱

1答えて

Pythonを使ってペアのリストを減らす

リストの要素をまとめてペアにして、最終的なオブジェクトを作成しようとしています。これはオブジェクトの合計と似ています。私はreduceの単純なバリエーションを使用しようとしています。ここでは、これを行うためのフラットリストではなく、ペアのリストを検討します。私は数字numsのリストの各要素に固有の合計に追加情報を追加したい除い nums = [1, 2, 3] reduce(lambda x,

3熱

1答えて

sparkアキュムレータのリセット

ドライバでスパークアキュムレータをリセットする方法があるため、エグゼキュータのアキュムレータもクリーンアップされます。実際にはList> のAccumulatorを持っています。すべてのExecutorがタプルをアキュムレータに追加し、ドライバがそれを読み込みます。問題は、エグゼキュータのヒープがいっぱいになることです。ドライバがすべてのデータを読み込むと、エグゼキュータはローカルデータを必

0熱

1答えて

スパークスカラは、複数の列から文字列の配列を取得します

私はスカラでスパークを使用しています。私は次の出力を取得する方法を知りたいのです [文字列型文字列配列の配列でなければなりません[以下の画像の列アキュムレータを参照してください]：入力を想像してみて私の本当のデータフレームで] 私は3列以上のものを持っています。私は数千の列を持っています。希望する出力を得るにはどうすればよいですか？

1熱

2答えて

テキストファイルからの非負の数の平均を計算する

整数のテキストファイルを読み込み、リストにして、すべての整数の平均を計算し、すべての非負の整数の平均を計算し、print最大と最小。私はすべての整数の平均を計算することができましたが、すべての非負整数の平均と最大値と最小値を得ることは困難です。ここ私がこれまで持っているものです。 file = open("numberlist.txt", "r") sum = 0 list = []

0熱

1答えて

結果の値を累積したいが、VERILOGで二重代入を禁じることなく変数をゼロに初期化することはできない

ステップごとに方程式の部分を計算し、入力を更新してやり直すFSMを作成した何度も。今、私は、この繰り返しのたびにこの結果を蓄積したいと思っています。と仮定valが生成される値であり、ZVALが連続した値のsumatoryであり、私はこの always @ (sum_val) Zval = Zval + val; ようなレジスタを使用し、この always @ (enable) Zval