PyFlink 数据流 API 支持开窗
PyFlink datastream API support for windowing
Apache Flink 的 Python SDK(PyFlink) Datastream API support operators like Windowing? Whatever examples I have seen so far for Windowing with PyFlink, all use the Table API. The Datastream API 是否支持这些运算符,但看起来这些运算符还不能通过 PyFlink 获得?
谢谢!
没错,PyFlink 还不支持DataStream window API。关注 FLINK-21842 以跟踪此问题的进展。
Apache Flink 的 Python SDK(PyFlink) Datastream API support operators like Windowing? Whatever examples I have seen so far for Windowing with PyFlink, all use the Table API. The Datastream API 是否支持这些运算符,但看起来这些运算符还不能通过 PyFlink 获得?
谢谢!
没错,PyFlink 还不支持DataStream window API。关注 FLINK-21842 以跟踪此问题的进展。