我正在尝试在 RDD 上使用 map -> combineByKey -> map 进行转换。 我有这个驱动程序方法，它初始化了sparkSession： def main(args: Array...