Spark: почему foreach() не работает в rdd.foreachPartition?

#apache-spark #spark-streaming Вопрос: Мой код приведен ниже. stream .map(x => { x.value() }).foreachRDD( rdd => { rdd.foreachPartition( (records: Iterator[String]) => { println(records.length) // length of records records.foreach( x => {…