I'm wanting to know if it's possible in Flink to parse strings into a dynamic JSON object that doesn't require me to know the primitive type details at compile time. We have over 300 event types to process, and I need a way to load the types at runtime. I only need to know if certain fields exist on the incoming objects, and the object schemas are all different except for certain fields. Every example I can find shows Flink users specifying the full type information at compile time, but there's no way this will scale.
It's possible for us to lookup primitive type details at runtime from JSON, but I'll still need a way to process that JSON in Flink to extract the metadata if it's required. So, that brings me back to the original issue. How can I do this in Flink? -- Devin G. Bost
