Scala:迭代配置单元表的多个记录

Question

我定义了一个val nameAgeData，其中源是一个配置单元表。val nameAgeData的输出如下所示：

+----------+
|  name_age|
+----------+
|   john_15|
|    ron_12|
+----------+

我正在尝试调用另一个函数并为每个值执行：

val nameAgeList= nameAgeData.collect.toList
nameAgeList.foreach  ( id =>
executeData(name = name,
name_and_age = id,
city = city)
)

但这是抛出错误。 请问我在这里做错了什么吗？

Answer 1

您的nameAgeData值似乎是 SparkDataFrame，因此nameAgeList是一个List[Row]。 您必须从Row中提取数据，即：

val nameAgeList: List[String] = nameAgeData.collect.toList.map{r:Row => r.getAs[String]("name_age")}