Hi Timo,
Thank you for ur clarification, it is very useful to me, I am also
combining the realization of map function, trying to do implicit conversion
of case class, so that I can restore state from FS.
On Fri, Feb 5, 2021 at 10:38 PM Timo Walther <twal...@apache.org> wrote:
> Hi Xavier,
>
> the Scala API has special implicits in method such as `DataStream.map()`
> or `DataStream.keyBy()` to support Scala specifics like case classe. For
> Scala one needs to use the macro `createTypeInformation[CaseClass]` for
> Java we use reflection via `TypeInformation.of()`. But Scala and Java
> analysis is completely different. So you cannot use a case class in Java
> API. Scala will fall back to Java though.
>
> I hope this helps.
>
> Regards,
> Timo
>
>
> On 05.02.21 10:54, Xavier wrote:
> > Hi Utopia,
> > Have u fixed this problem? I also meet this problem, so I
> transferred the
> > case class to Java POJO, then this problem was fixed.
> >
> >
> >
> > --
> > Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
> >
>
>
--
Best Regards,
*Xavier*
