問題タブ [graphframes]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
scala - Scala/Spark のグラフフレーム エラー
Scala 2.11 で次のコード行を Databricks に記述しました。
しかし、それは私にこれらのエラーを返します:
前もって感謝します 心からアントニオ
scala - GraphFrames の aggregateMessages からの出力なし
GraphFrames を使い始めたばかりで、ドキュメントに従っていますが、aggregateMessages 関数から結果を取得できません (空のデータフレームが返されます)。これが私の問題の単純化された例です: 私の頂点RDDが頂点属性のないtestGraph単一の頂点のみで構成され、Y私のedgeRDDが次のような2つのレコードで構成されるように呼び出されたGraphFramesオブジェクト:
min_ts1ここで、 の値を にdst送信min_ts2し、 に送信する単純なアルゴリズムを実装したいと考えていますsrc。このアルゴリズムを実装するために使用しているコードは次のとおりです。
ここにいくつかの null 値があることに気付きましたが、いずれにせよ、メッセージ パッシング アルゴリズムが次のことを行うことを期待します: 最初のレコードを見て、 to のメッセージと to のメッセージを送信20します。次に、2 番目のレコードを見て、X へのメッセージと へのメッセージを送信します。最後に、結果が のメッセージの合計が であることを示し、頂点RDD に含まれていないため、結果に記録がないことを期待します。また、頂点RDDに含まれている場合、両方のメッセージが.YnullXnull-10YY10XXnullnull
ただし、取得しているのは空のRDDです。空の結果が得られる理由を誰かが理解するのを手伝ってくれませんか?