Можно ли делать прогнозы для потока данных в Apache Flink, используя модель, которая уже обучена в пакетном режиме?
Функция прогнозирования из svm требует в качестве входных данных набор данных и не принимает поток данных.
К сожалению, я не могу понять, как заставить его работать с функцией flatpMap / map.
Я обучил свою SVM-модель следующим образом:
val svm2 = SVM ()
svm2.setSeed (1)
svm2.fit (trainLV)
val testVD = testLV.map (lv => (lv.vector, lv.label))
val evalSet = svm2.evaluate (testVD)
и сохранил модель: val modelSvm = svm2.weightsOption.get
Затем у меня есть входящий поток данных в потоковой среде:
dataStream [(Int, Int, Int)], который должен быть двоично классифицирован с использованием модели svm.
Спасибо!
