2017-03-31 9 views
0

私は公園ペアrdd(key、Array(value1、value2、value3 .....))を持っています。 私はどのスカラー文を書くべきですか? どうすればフラットこのRDDと新しいRDD作成することもできます(キー、VALUE1)、(キー、値2)、(キー、値3)....spark rddどのようにフラットにキー - 配列(値)のペア

+1

おそらくちょうど 'rdd.flatMapValues(X => x)は' – mtoto

答えて

0
rdd.flatMap{case (k,v) => v.map(vx => (k,vx))} 
1

@motoが言ったように、それは単に

です

rdd.flatMapValues(v => v)

より冗長が、間違いなく、より読みやすいオプション:

rdd.flatMap { 
    case (key, values) => values.map(v => key -> v) 
} 
関連する問題