filter算子返回一个新的RDD，该RDD由经过函数计算后返回值为true的输入元素组成

第1题：

第2题：

第3题：

第4题：

以下属于spark启动后进程的是（）

• A、rdd是由一系列的partition组成的
• B、原子性
• C、算子作用在partition上
• D、每个rdd都会提供一批最优的计算位置

第5题：

groupByKey算子在一个（K，V）的RDD上调用，返回一个（K，Iterator[V]）的RDD

第6题：

第7题：

第8题：

第9题：

reduceByKey算子在一个（K，V）的RDD上调用，返回一个（K，V）的RDD，使用指定的reduce函数，将相同key的值聚合到一起

第10题：

mapPartitions算子类似于map，但独立地在RDD的每一个分片上运行，因此在类型为T的RDD上运行时，func的函数类型必须是Iterator[T]=>Iterator[U]