此处给出的解决方案在Pyspark中。我正在寻找Scala的解决方案。
How can you efficiently build one ML model per partition in Spark with foreachPartition?
[email protected],向我付款:$$$$$$$ 40.00 $ 4钱,请给我另外一个,请给我$$$]