Hi everybody, since here at Okkam we didn't find any "native" Flink map functions that already permit to pass from JSON strings to POJOs (and vice versa), we decided to share with the Flink community a simple implementation for these 2 tasks: - JSON (string) to POJO [1] - POJO to JSON (string) [2]. A Flink Main class that use those 2 functions can be found at [1].
Any feedback is welcome! Best, Flavio [1] https://github.com/okkam-it/flink-examples/blob/master/src/main/java/it/okkam/flink/Json2PojoExample.java [2] https://github.com/okkam-it/flink-examples/blob/master/src/main/java/it/okkam/flink/json/JsonStringToPojo.java [3] https://github.com/okkam-it/flink-examples/blob/master/src/main/java/it/okkam/flink/json/Pojo2JsonString.java
