在编写Spark程序时,我遇到了这种toLocalIterator()方法.早先我只使用iterator()方法.
如果有人曾经使用过这种方法,请扔一些灯.
我在Spark程序中使用foreach和foreachPartition方法时遇到过.
我可以将foreach方法结果传递给toLocalIterator方法或反之亦然.
toLocalIterator() -> foreachPartition()
iterator() -> foreach()
Run Code Online (Sandbox Code Playgroud)