Re: Requirements for POJO serialization

2023-04-12 Thread Shammon FY
Hi Alexis Flink will recognize the POJO class and use PojoTypeInfo to serialize and deserialize it. For specific constraints on POJO classes, please refer to [1]. Users can also define serialization methods for their own classes, as you mentioned in the email [1] https://github.com/apache/flink

Requirements for POJO serialization

2023-04-11 Thread Alexis Sarda-Espinosa
Hello, according to the documentation, a POJO must have a no-arg constructor and either public fields or public getters and setters with conventional naming. I recently realized that if I create an explicit TypeInfoFactory that provides Types.POJO and all other required details, the getters and se