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