Java – foreach function does not work in spark dataframe

According to the dataframes API, the definition is:

public void foreach(scala.Function1<Row,scala.runtime.@R_841_2419@edUnit> f)

Apply function f to all rows

But when I want

Dataframe df = sql.read()
    .format("com.databricks.spark.csv")
    .option("header","true")
    .load("file:///home/hadoop/Desktop/examples.csv");

df.foreach(x->
{
   System.out.println(x);
});

I received a compile - time error Is there anything wrong?

Solution

You can convert it to Java RDD to use lambda, as follows:

df.toJavaRDD().foreach(x->
   System.out.println(x)
);