SparkのIndexで要素を取得する方法RDD（Java）scalaではない、Python

Question

私はRDDの最初の要素を与えるrdd.first()メソッドを知っています。

また、私に最初のnum要素を与える方法rdd.take(num)があります。

インデックスで要素を取得する可能性はありますか？

Answer 1

RDDは索引付けされていませんが、ほとんどの場合、順序が保証されず、効率的な単一項目アクセスがサポートされません。

あなた

• zipWithIndexとfilterことができます。
• zipWithIndex、スワップ要素およびlookup。

ただし、これは推奨されていません。リニアスキャンが必要で、非確定的な動作をする可能性があります。