Mysql
 sql >> Datenbank >  >> RDS >> Mysql

Nichtübereinstimmung des Scala-Spark-Typs Einheit gefunden, erforderlich rdd.RDD

Entfernen Sie das abschließende .collect().foreach(println) . Nach Aufruf von collect , haben Sie kein RDD mehr – es wird einfach zu einer lokalen Sammlung.

Anschließend beim Aufruf von foreach es gibt Unit zurück - foreach dient zum Ausführen von Nebeneffekten wie dem Drucken jedes Elements in einer Sammlung. usw.