0
私はspark 2.1とScalaのいくつかの旅行で人の距離を計算しようとしています。Spark Scala - reducebykey =>値の配列の2番目の要素を取得する方法?
私は鍵が人物であることをpairedRDDを持っており、リスト、旅のリスト:私はキロの数を追加したいと思い
:(性別、キロのNB)キーによって、私は第2の値(kmのnb)にアクセスする必要がありますが、私はどのように見つけません。 私が試した:
私はスカラ座に新しいです、とのpythonから来る私はtはそれを得る "ドン: -/
編集1
編集2
私はそれを得ることはありません4編集:私は私の変数名を配合していますように編集3
とjoinedrddのサンプル210
私はいくつかのjoined_rddデータ-joinedrddは 'trajets_par_cycliste' の別名であることを示すために、質問を編集し –
ペア '(sex、nb of km)'は 'rdd'のレベル3にネストしています。 – mrsrinivas
...どのようにそれをフェッチするのですか? –