Hi All - Trying to achieve the following -
1. Ingest the data from RMQ 2. Decompress the data read from RMQ 3. Window it for 5 mins and process the data 4. Sink the processed data. Was able to achieve step1 and step 2, however realized that Pyflink *DataStream *doesn't have window support. Given the option that we can use TableAPI for windowing, I am trying to convert DataStream into *TableAPI*, but I have been facing issues with conversion. Could anybody help me find the right way of conversion? *DataStream *has data of type *Pandas DataFrame*. Appreciate any help here. Thanks -- DREAM IT, DO IT
