PyFlink 数据流 API 对窗口的支持

Question

Apache Flink 的 Python SDK (PyFlink) Datastream API 是否支持像 Windowing 这样的运算符？到目前为止，无论我见过多少使用 PyFlink 进行窗口化的示例，它们都使用了 Table API。 Datastream API 确实支持这些运算符，但看起来这些运算符还不能通过 PyFlink 获得？

谢谢！

Answer 1

没错，PyFlink 还不支持 DataStream 窗口 API。关注 FLINK-21842 跟踪此问题的进展。

Answer 2

更新： 现在已包含，并且此问题中的错误https://issues.apache.org/jira/browse/FLINK-21842已解决。

这里是包含翻滚窗口的更新文档：https://nightlies.apache.org/flink/flink-docs-master/api/python/reference/pyflink.datastream/window.html