Can I somehow in PyFLink convert a kinesis stream source from an unbounded source to a bounded source. I saw it's possible for Kafka [1]. If I can get my kinesis source to be bounded, then I should be able to use "batch" mode, which should provide me access to pandas in UDAF on windowing operations. --- [1] https://stackoverflow.com/a/65716165