开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

想用flink调用训练好的python机器学习模型,试了java加载不了这个模型,该怎么办呢?

想用flink调用训练好的python机器学习模型,试了java加载不了这个模型,该怎么办呢?

展开
收起
圆葱猪肉包 2023-04-19 16:33:01 382 0
2 条回答
写回答
取消 提交回答
  • 公众号:网络技术联盟站,InfoQ签约作者,阿里云社区签约作者,华为云 云享专家,BOSS直聘 创作王者,腾讯课堂创作领航员,博客+论坛:https://www.wljslmz.cn,工程师导航:https://www.wljslmz.com

    要使用Flink调用训练好的Python机器学习模型,可以考虑以下方法:

    1. 使用Java调用Python的接口

    可以使用Java的Process类或Jython等工具,调用Python的接口进行模型预测,将预测结果传回Java程序。

    1. 将模型转化为Java模型

    可以使用第三方工具(如ONNX、TensorFlow等)将Python模型转化为Java模型,以便在Java程序中直接加载和调用。这样做可能需要对Python模型进行一些修改和重新训练,以便能够成功地转化为Java模型。

    1. 使用Python UDF

    可以将Python模型封装为Python UDF,然后在Flink任务中通过Python UDF的方式调用。这种方式需要在Flink任务中使用Python环境(如PyFlink),使得Flink任务能够调用Python UDF。

    2023-04-30 23:07:17
    赞同 展开评论 打赏
  • pyflink在某些高级算子上的支持暂不完整,可以移步到pyflink交流群(34004474)提问~,此回答整理自钉群“【③群】Apache Flink China社区”

    2023-04-19 22:32:37
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Spring Cloud Alibaba - 重新定义 Java Cloud-Native 立即下载
    The Reactive Cloud Native Arch 立即下载
    JAVA开发手册1.5.0 立即下载