Hi,
Pyflink should support window api. You can read this document. https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/dev/python/datastream/operators/windows/ Hope this helps. Best, Yuan On Tue, 16 Aug 2022 at 3:11 PM, Ramana <ramana...@gmail.com> wrote: > 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 >
