如何在 Spark/Scala 中将 Array[String] 转换为 Array[Any]

Question

我正在尝试为 Graphframes 中的 parallelPersonalizedPageRank 算法生成 sourceIds 并按如下方式调用算法：

val PPRIdCS = studentCS.select("id").collect.map(row => row.getString(0))
val ranksCS = studentGraph
  .parallelPersonalizedPageRank
  .resetProbability(0.15)
  .maxIter(10)
  .sourceIds(PPRIdCS)
  .run()

我得到的错误信息如下：

Message: <console>:46: error: type mismatch;
found   : Array[String]
required: Array[Any]
Note: String <: Any, but class Array is invariant in type T.
You may wish to investigate a wildcard type such as `_ <: Any`. (SLS 
3.2.10).sourceIds(PPRIdCS)

我无法弄清楚将 String 类型转换为 Any 类型的方法是什么，或者在生成 PPRIdCS 时将 String 映射到 Any 的方法是什么。谢谢！

Answer 1

只要明确类型：

val PPRIdCS: Array[Any] = studentCS.select("id").collect.map(row => row.getString(0))

或更好

val PPRIdCS: Array[Any] = studentCS.select("id").collect.map(row => row(0))

Answer 2

正如我的评论所述，您可以映射到 .asInstanceOf[Any]。

示例：

val arr = Array("a", "b") 
val asAny = arr.map(_.asInstanceOf[Any])

这似乎也有效...

val asAny = arr.asInstanceOf[Array[Any]]

现在这样做是假设您出于某种原因不想明确指定其他答案所指出的类型。

如何在 Spark/Scala 中将 Array[String] 转换为 Array[Any]

How to convert Array[String] to Array[Any] in Spark/Scala

arrays

scala

graph

apache-spark

graphframes