Hello everybody!
my RMQSource function receives string with JSONs in it.
Because many operations in Flink rely on Tuple operations, I think it is a good idea to convert JSON to Tuple.
I believe this task has been solved already :)
what's the common approach for this conversion?
Thank you,
Alex