如何在 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

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

例子：

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

这似乎也有效......

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

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