概览
This documentation is for an unreleased version of Apache Flink. We recommend you use the latest stable version.

Python API #

PyFlink

PyFlink 是 Apache Flink 的 Python API,你可以使用它构建可扩展的批处理和流处理任务,例如实时数据处理管道、大规模探索性数据分析、机器学习(ML)管道和 ETL 处理。 如果你对 Python 和 Pandas 等库已经比较熟悉,那么 PyFlink 可以让你更轻松地利用 Flink 生态系统的全部功能。 根据你需要的抽象级别的不同,有两种不同的 API 可以在 PyFlink 中使用:

  • PyFlink Table API 允许你使用类似于 SQL 或者在 Python 中处理表格数据的方式编写强大的关系查询。
  • 与此同时,PyFlink DataStream API 允许你对 Flink 的核心组件 statetime 进行细粒度的控制,以便构建更复杂的流处理应用。

如果你有兴趣使用 PyFlink,可以尝试以下教程:

如果你想了解更多关于 PyFlink 的示例,可以参考 PyFlink 示例

这些参考文档涵盖了 PyFlink 的所有细节,可以从以下链接入手:

如果你遇到困难,请查看我们的社区支持资源,特别是 Apache Flink 的用户邮件列表,Apache Flink 的用户邮件列表一直是所有 Apache 项目中最活跃的项目邮件列表之一,是快速获得帮助的好方法。