开发者社区> 问答> 正文

PyFlink 1.11 的功能是什么?

PyFlink 1.11 的功能是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 15:47:41 314 0
1 条回答
写回答
取消 提交回答
  • 我们将视角由远方拉近到 Flink 1.11 版本 PyFlink 的核心功能,PyFlink 会围绕着 功能,性能和易用性不断努力,在 1.11 在功能上会增加 Pandas UDF 的支持,这样Pandas 生态的实用类库功能可以在 PyFlink 中直接使用,比如累积分布函数, CDF 等。还会增加 ML Pipeline API 的支持,这样大家可以利用 PyFlink 完成一些机器学习场景的业务需求,我这里是一个使用 pyFlink 完成 KMeans 的示例。

    2021-12-07 15:49:31
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Python on Flink & Flink on Zeppelin 立即下载
Building Robust ETL Pipelines with Apache Spark 立即下载
Runtime Improvements for Flink as a Unified Engine 立即下载