問題タブ [accumulator]

ノードを使用してサブディレクトリを含むディレクトリに含まれる一意のファイル名のリストを取得したいと考えていましたが、各コールバックの結果を組み合わせるのに問題がありました。コールバックからファイル名をログに記録するだけで発生する重複操作を避けたいと思っていfs.statます。

もちろん、これはconsole.log()関数の呼び出しが早すぎて、望ましくない結果をもたらします。作業する一連のファイル名を取得するにはどうすればよいですか。readdirSync非同期メソッドを使用して、つまりandを使用せずにこれを行う良い方法はありstatSyncますか?

MongoDB に次のデータがあるとします。

すべての「もの」セットの結合を取得することは可能ですか? 例えば["A","B","C"]

使ってみました$addToSet

しかし、それはセットのセットを作成します[ ["A", "B"], ["B", "C"] ]

私が持っているとしましょう

vすべての行に、次のような 1 秒のルックバック時間間隔内の sの合計が含まれるように、列 s を追加したい

では、この追加の列を生成するにはどうすればよいsですか?

間隔はオーバーラップする必要がありますが、データフレームのすべての行 (データポイント) に正しいエンドポイントが必要です。つまり、データフレームのすべての行 (データポイント) は、そのサイズの間隔の正しいエンドポイントでなければなりません。

編集: 以下の答えは正しくありませんか?完了

編集：必ずしも1秒だけではなく、14ミリ秒などの一般的な時間間隔でソリューションが機能することを望みます。

どうですか

私は得た

インデックス 1 の行は間違っていませんか? s at 03:39:42.500914 は 2+1=3 である必要があります。2 ではありません。最初の 2 行は 400 ミリ秒以内にあるため、それらを合計する必要があります。なぜそうしないのですか？

編集：試してみると

時間間隔が短くても、実際にはそのグループ化を実行します。

では、TimeGrouper が配置する区切り記号 (区切り記号) はどこにあるのでしょうか? 間隔の右端点を、見ている行 (s が対応する行) と一致させたい

だから私はハングマンゲームを作っています。現時点では、ユーザーが何回間違った推測をしたかを示すアキュムレーターを作成しようとしています (6 回間違った推測をすると、ユーザーは負けます)。ただし、strikeCounter が 0 に設定されたままになり、その理由がわかりません (したがって、ユーザーが何回間違った推測をしても、常に 1 つのストライクがあることが出力されます)。誰かが私のエラーがどこにあるかを確認するのを手伝ってくれますか? ありがとうございました！

私のアキュムレータは、RDD の foreach 操作でアキュムレータを更新した後の Array[Array[Int]] です。accumulator(0) は期待どおりですが、accumulator(1) は完全に失われた Array(0,0,0) です。

RDD 内では、アキュムレータ値は Array(Array(4,5,6),Array(4,5,6)) RDD 外では、アキュムレータ値は Array(Array(4,5,6),Array(0,0,0) です)))

以下はコードです

結果: RDD 内では、アキュムレータ値は Array(Array(4,5,6),Array(4,5,6)) です RDD 外では、アキュムレータ値は Array(Array(4,5,6),Array(0,0) です,0))

しかし、RDDの外で私が期待しているのは Array(Array(4,5,6),Array(4,5,6)) です

アキュムレータを使用していますが、これらのオブジェクトがスレッドセーフかどうかを知りたいですか?

accumIntのタイプですAccumulatorParam<Integer>。

AccumlatorThreadクラス：

この動作は、スレッド セーフではないことを示しています。何か不足していますか？