Apache Flink 有状态函数 python 对比 java 性能

Question

开发apache flink stateful function时使用python和java有什么优缺点

• 有什么性能差异吗？同样的操作，哪个效率更高？
• 我们能否在 python 上完全开发应用程序？
• 哪些功能一个支持，另一个不支持。

Answer 1

StateFun支持内嵌函数和远程函数。

• 嵌入式函数被捆绑并部署在 运行 Flink 的 JVM 进程中。因此，它们必须以 JVM 语言（如 Java）实现，并且它们将是最高性能的。缺点是功能代码的任何改动都需要重启Flink集群。

• 远程函数是在单独的进程中执行的函数，并且由 Flink 集群针对发送给它们的每个传入消息调用。因此，预计它们的性能不如嵌入式函数，但它们在以下方面提供了极大的灵活性：

  • 选择实现语言
  • 快速放大和缩小
  • 出现故障时快速重启。
  • 滚动升级

Can we develop the application completely on python?

是否可以在 Python 中完全开发应用程序，请参阅 python greeter example。

What are the features that one supports and the other does not.

目前仅Java SDK:

支持当前功能

• 从入口到函数的更丰富的路由逻辑。您可以通过代码描述的任何路由逻辑。
• 还有一些状态类型，例如 table 和缓冲区。
• 将现有的 Flink 源和接收器公开为入口和出口。