java - foreach 函数在 Spark DataFrame 中不起作用

Question

根据DataFrames API，定义是:

public void foreach(scala.Function1<Row,scala.runtime.BoxedUnit> f)

将函数 f 应用于所有行。

但是当我想这样的时候

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);
});

我收到编译时错误。有什么错误吗？

Answer 1

您可以将其转换为 Java RDD，以便像您一样使用 lambda:

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