5、演示flatMap算子的用法（RDD）

flatMap算子是一种对RDD进行操作的方法，它可以将一个RDD中的每个元素转换为多个元素，并将这些元素合并成一个新的RDD。具体来说，flatMap算子会对每个输入元素应用一个函数，该函数返回一个可迭代对象，然后将所有可迭代对象中的元素合并成一个新的RDD。下面是一个演示flatMap算子用法的例子：

假设我们有一个包含多个句子的RDD，我们想要将每个句子拆分成单词，并将所有单词合并成一个新的RDD。我们可以使用flatMap算子来实现这个功能，具体代码如下：

sentences = sc.parallelize(["Hello world", "How are you"])
words = sentences.flatMap(lambda sentence: sentence.split(" "))

在这个例子中，我们首先创建了一个包含两个句子的RDD，然后使用flatMap算子将每个句子拆分成单词，并将所有单词合并成一个新的RDD。最终，我们得到了一个包含所有单词的RDD。