pyspark.RDD.flatMapValues¶
-
抽樣。flatMapValues( f:可調用的((V],Iterable(U]] )→pyspark.rdd.RDD(元組(K,U] ] ¶ -
通過每個值的鍵-值對抽樣通過flatMap功能在不改變的關鍵;這也保留原抽樣的分區。
例子
> > >x=sc。並行化(((“一個”,(“x”,“y”,“z”]),(“b”,(“p”,“r”))))> > >deff(x):返回x> > >x。flatMapValues(f)。收集()[(' a ', ' x '), (' a ', ' y '), (' a ', ' z '), (“b”,“p”) (“b”,“r”)]