[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Flink JSON (string) to Pojo (and vice versa) example

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!