Spark UDF返回多个项目

Question

Spark UDF是否有可能返回多个值？如果是这样，则如何在数据范围API中访问单个项目。

Answer 1

您有三个选项：

• 返回相同类型项目的Seq创建array列。

  udf(() => Seq(1.0, 2.0, 3.0))
  

• 返回Map：

  udf(() => Map("x" -> 1.0, "y" -> -1.0))
  

• 返回产品（元组或案例类的实例）以创建struct列。

  udf(() => (1.0, "foo", 5))
  

Answer 2

您可以使用 struct 和 array 方法来实现这一目标。

请检查此处，以获取@ramesh的非常简单简便的答案