apacheflink中的java状态函数远程模块


0

当我检查状态函数模块时,我发现了以下结果。

https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.0/sdk/python.html->pythonsdk支持作为远程模块。

https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.0/sdk/java.html->Java SDK作为一个嵌入式的_模块来支持。

https://ci.apache.org/projects/flink/flink-statefun-docs-release-2.0/sdk/modules.html->此模块类型可以支持任意数量的语言SDK。远程模块通过YAML配置文件在系统中注册。

有状态函数应用程序使用http与apacheflink运行时通信。pythonsdk附带了一个RequestReplyHandler,它 root据restfulhttppost自动分派函数调用。RequestReplyHandler可以使用任何HTTP框架公开。

如何用JAVA服务请求?有没有Java SDK的远程函数示例?

我还可以混合嵌入式和同位置/远程功能吗?

1 答案


0
是否有远程Java SDK

目前还没有Java远程SDK,但 root据Apache Flink dev邮件列表上的讨论,我预计很快就会看到一个。

像python这样的远程sdk实际上是通用Http接口的方便包装器。我的意思是在statefun运行时中没有特定于python的逻辑,所以现在可以用任何语言实现远程函数。显然,flink社区不想强迫人们这样做,因此新的远程sdk正在为将来的版本开发。

我还可以混合嵌入式和同位置/远程功能吗?

是的,没有什么特别的魔力。只需在一个部署中包含这两个模块就可以了。两个模块中的函数可以任意地相互传递消息。

您可以参考这个模型服务示例,它既包含嵌入式java函数,也包含远程python函数。

https://github.com/ververica/flink-statefun-workshop


我来回答

写文章

提问题

面试题