Hi all, Recently, we are facing with the demand to mimic Apache Flink's keyed window operator in Pulsar Functions.
This is because, with simple keyed window functions, we could remove the need to deploy and run a separate computing cluster with little computations to do. Therefore, I've drafted PIP-53: Keyed window function to enable this feature in Pulsar. This design doc is available at https://docs.google.com/document/d/1C9QbtBknIUd2yjFwa5yG8Enr8RkCDMqiEV-5mglyqr4/edit# Please help to review, any ideas are welcome. Best, Yijie
