【发布时间】:2021-03-21 17:58:15
【问题描述】:
Apache Flink 的 Python SDK (PyFlink) Datastream API 是否支持像 Windowing 这样的操作符?到目前为止,我看到的任何使用 PyFlink 进行窗口化的示例都使用 Table API。 Datastream API 确实支持这些运算符,但看起来这些还不能通过 PyFlink 获得?
谢谢!
【问题讨论】:
标签: apache-flink pyflink
Apache Flink 的 Python SDK (PyFlink) Datastream API 是否支持像 Windowing 这样的操作符?到目前为止,我看到的任何使用 PyFlink 进行窗口化的示例都使用 Table API。 Datastream API 确实支持这些运算符,但看起来这些还不能通过 PyFlink 获得?
谢谢!
【问题讨论】:
标签: apache-flink pyflink
没错,PyFlink 还不支持 DataStream 窗口 API。关注FLINK-21842 跟踪此问题的进展。
【讨论】: