Java Spark Mongodb 连接器 joda 节省时间

问题描述

当我使用 spark 连接器在 mongodb 中保存人物数据集时，它创建了 createdTimestamp 的空对象，如下图所示，我想用 joda 时间的 DateTime 对象保存 createdTimestamp。

伪代码：

Dataset<Person> person = person_records.map(person -> {
         person.setAge(10);
         DateTime ts=DateTime.Now(DateTimeZone.UTC);//date time is joda time 
         person.setCreatedTimestamp(ts);
         person.setApproved(true);
                 return   person;
    },Encoders.bean(Person.class));
    MongoSpark.save(person);

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）