按列划分并映射到该分区上我有一个sparksqldataframe,并且有一个函数需要应用于partition_col相同的所有行。在 到目前为止,我知道我可以将DataFrame转换为RDD并在那里应用mapPartiti ...2024-10-01 已阅读: n次