flatMap (). # 将函数应用于RDD 中的每个元素,将返回的迭代器的所有内容构成新的RDD。通常用来切分单词。 >>> rdd = sc.parallelize(['ad cd', ...
確定! 回上一頁