のApache-スパーク：関数にパラメータとして反復処理可能[文字列]を渡す方法

Question

私は、キーと値のペアでgroupByKeyを使用していた私だタイプの出力[（文字列、反復処理可能[文字列]）]

私が呼び出しています上記の出力上のマップ変換に関数が宣言されていますが、関数宣言でエラーが発生しています。

def getStr (uid : String, locations : Array[]) : String = { 
    return "test" 
} 

Iterable [String]を関数パラメータとして使用する方法がわかりません。

Answer 1

RDDはRDD[(String, Iterable[String])]型を持つ場合、そのレコードをマップするためにあなたはRDDのレコードの同じタイプの単一の引数を受け取る機能、すなわち必要があります：あなたは迷っている場合は

def getStr(record: (String, Iterable[String])): String = { "test" } 

を何Iterableで行うことができます - docsを参照してください。

最も簡単なアプローチ（必ずしも最高のパフォーマンスを発揮するとは限りません）は、リストに変換してより豊かなAPIを得ることがあります。それが空の場合、イテレータの最初の項目、またはデフォルト値を取得する：OPは、我々は彼が何をしたいのかわからない場合は反復可能に `toList`を使用する必要がある場合

def getStr(record: (String, Iterable[String])): String = record match { 
    case (s, iter) => iter.toList.headOption.getOrElse("UNKNOWN") 
}