apache-flink - PyFlink 数据流 API 支持窗口化
问题描述
Apache Flink 的 Python SDK ( PyFlink ) Datastream API 是否支持 Windowing 等运算符？到目前为止，我看到的任何使用 PyFlink 进行窗口化的示例都使用 Table API。Datastream API确实支持这些运算符，但看起来这些还不能通过 PyFlink 获得？
谢谢！
解决方案
没错，PyFlink 还不支持 DataStream 窗口 API。按照FLINK-21842跟踪此问题的进展。
推荐阅读
- ios - MicroBlink SDK 的 USDL 组合识别器 documentDataMatch 总是返回 true
- python - 如何将列标签转换为列中的值？
- sqlite - 在我的 INSERT INTO 语句中运行 COUNT 时遇到问题
- regex - 如何使用 different_url+last_part 添加 nginx rewrite url+last_part？
- java - java.sql.SQLException：不能为 SELECT 发出 executeUpdate() 或 executeLargeUpdate()
- c# - 如何使用 C# 在 ASP.NET 中将下拉列表与 Web 服务绑定
- javascript - 选择整个字典的值
- python - 如何使用 python 在 EventHub 消息中发送属性详细信息？
- css - 如何从代码库中摇树未使用的样式
- f# - 未处理的异常：System.ArgumentOutOfRangeException：特征列“特征”的架构不匹配：预期向量
, 得到向量