I'm attempting to write a simple PyFlink datastream application that reads complex input json files, and I'd like to deserialize it into a much simpler tuple structure (perhaps flattened). Can anyone point me to an example of how I would do this? Do I need to create my own Deserializer? Or can I provide some json path type mapping config to select the fields I care about?