如何在Java中构建编码器 >

Question

我正在用Java实现一个spark进程，并希望从相同参数化类型的RDD中为自己创建的MyPojo类创建一个Dataset<Try<MyPojo>>，其中Try是scala Try。在scala中，编码器将隐式地制作，但是在java中，我需要显式提供它。

现在，我可以使用Encoder<MyPojo>获得工作的Encoders.bean(MyPojo.class)。而且我希望有一些代码可以根据scala隐式使用的Encoder<Try<T>>来构建Encoder<T>。但我找不到它。

[注：我只是在scala中尝试过，没有发现类型为Try的隐式...因此问题也在scala中有效]

所以，我应该怎么做？

Answer 1

经过一番搜索，我得出的结论是>

1. 不可能（或者可能会太复杂）