Spark Java-如何将Java对象存储在Spark DataFrame中？

Question

我在Java中使用Spark，我想将Java对象存储在Spark DataFrame中。我搜索了许多博客和链接，但找不到这样做的方法。假设我的对象类是 -

class Temporary{
    Integer id;
    String name;
    String another;

    public Temporary(Integer id, String name, String another){
        this.id = id;
        this.name = name;
        this.another = another;
    }
}

我有一个DataFrame DF，我想将此临时类的对象存储在列中。假设我正在添加一个将具有临时类对象的数组类型的临时。我想做类似的事情 -

df = df.withColumn("Temporary", functions.array(
                               functions.expr("CASE WHEN something_is_true THEN Temporary(1,"john","tempstring") ELSE empty_object END"),
                               functions.expr("CASE WHEN something_else_is_true THEN Temporary(2,"johny","tempstring") ELSE empty_object END")
                              ));

// expected result would be 

+------------------------------------------+
|                Temprorary                |
+------------------------------------------+
|  [Temproary_class_object, empty_object]  |
+------------------------------------------+

我知道这是行不通的，因为Expr仅接受SQL字符串而不是对象。有什么办法吗？任何帮助将不胜感激。