如何将每个RDD分区限制为只有'n‘个记录？

在Spark中，可以使用repartition或coalesce方法将RDD的分区数量限制为'n'个记录。

1. repartition方法：该方法会对RDD进行重新分区，可以将RDD的分区数量增加或减少。如果要将每个分区限制为'n'个记录，可以先计算出每个分区应该包含的记录数量，然后使用repartition方法将RDD重新分区为对应数量的分区。
2. 示例代码：
3. 示例代码：
4. coalesce方法：该方法可以将RDD的分区数量减少，但不能增加。如果要将每个分区限制为'n'个记录，可以先计算出每个分区应该包含的记录数量，然后使用coalesce方法将RDD减少为对应数量的分区。
5. 示例代码：
6. 示例代码：

这样，每个RDD分区就被限制为只有'n'个记录。这种限制可以在某些场景下提高计算性能，例如在数据倾斜的情况下，可以通过限制每个分区的记录数量来均衡负载。