Hey Everyone, How do I write the result of a join as an avro record or to a parquet file? From the Flink documentation, I can see that you need to supply the schema of the record or a POJO in order to create a new record. If you have two streams and you join them, how would you know the schema or POJO for your joined stream before joining the streams? Is there some way to extract the schema or create the POJO from your joined stream?