在apache flink中,是否可以使用已经批量训练过的模型对数据流进行预测?
支持向量机的预测函数需要一个数据集作为输入,而不需要数据流。
不幸的是,我无法弄清楚如何使用flatpmap/map函数。
我这样训练我的svm模型:
val svm2=svm()
svm2.调整速度(1)
svm2.fit(列车低压)
val testvd=testlv.map(lv=>(lv.vector,lv.label))
val evalset=svm2.evaluate(测试虚拟磁盘)
并保存模型:val modelsvm=svm2.weightsoption.get
然后在流式处理环境中有一个传入的数据流:
数据流[(int,int,int)]
应使用支持向量机模型对其进行二元分类。
谢谢您!
1条答案
按热度按时间q43xntqr1#
flink的ml库目前只支持批处理。如果你想用
DataStream
api,您需要实现自己的flatMap
/map
获取模型并将其应用于传入事件的函数。