在apache flin中嵌入现有的ML模型

Question

我们正在离线训练机器学习模型，并将它们保存在python pickle文件中。你知道吗

我们想知道如何将这些pickeled模型嵌入流（例如sensorInputStream>；PredictionJob>；OutputStream）中。你知道吗

Apache-Flink-ML似乎是用流数据训练模型而不是引用现有模型的正确选择。你知道吗

谢谢你的回复。你知道吗

谨致问候 洛蒙戈

Answer 1

根据您使用的模型，有两种可能的解决方案：

1. simples的想法可能是创建外部服务，调用模型并返回结果，然后用AsyncFunction简单地调用服务
2. 使用一些库，同样根据您的模型在ProcessFunction的open方法中加载预先训练好的模型。然后为每个到达的数据调用模型。你知道吗

第二种解决方案有两个缺点，第一个缺点是需要特定库的Java版本可用，另一个缺点是如果您希望能够随时间更新模型的元数据，则需要以某种方式将其外部化。你知道吗