apache-spark - FlatMap 値とその列インデックス

Question

次のデータセットがあるとしましょう

0,11,2,3,4,5,56,7
0,1,21,13,45,5,61,75
01,1,2,3,54,55,6,75

私がやろうとしているのは、値を列インデックスであるキーと値である値にフラットマップすることです。誰でも私にガイダンスを与えることができますか？列のインデックスを取得するのは難しいと思います。

Answer 1

キーがリストインデックスで、値がそのインデックスの値であるキーと値のペアの作成は、次のようになります。

rdd.flatMap(lambda x: enumerate(x))

これはもちろん、データがすでに RDD であることを前提としています。