【问题标题】:PyFlink datastream API support for windowingPyFlink 数据流 API 支持窗口化
【发布时间】:2021-03-21 17:58:15
【问题描述】:

Apache Flink 的 Python SDK (PyFlink) Datastream API 是否支持像 Windowing 这样的操作符?到目前为止,我看到的任何使用 PyFlink 进行窗口化的示例都使用 Table API。 Datastream API 确实支持这些运算符,但看起来这些还不能通过 PyFlink 获得?

谢谢!

【问题讨论】:

    标签: apache-flink pyflink


    【解决方案1】:

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

    【讨论】:

    • 谢谢!我猜 Flink 允许 Table 和 Datastream API 混合使用,所以可以通过使用相应的 Table API 来实现 Windowing。
    猜你喜欢
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2019-04-17
    • 1970-01-01
    • 2021-12-31
    • 2021-06-19
    • 2017-06-06
    • 1970-01-01
    相关资源
    最近更新 更多