Я разработал множественную линейную регрессию и Kmeans в Spark и Flink, чтобы сравнить их производительность в пакетном режиме (я использую Zeppelin для программирования и выполнения и Ganglia для измерения). Я прочитал в ответ на этот пост , что...

Когда я пытаюсь объединить элементы с помощью функции окна и сворачивания, некоторые элементы не удается объединить. Получение элементов из Kafka (value:0, value:1, value:2, value:3) и их агрегирование как нечетные и четные значения. Выход:...

Можно ли делать прогнозы для потока данных в Apache Flink, используя модель, которая уже обучена в пакетном режиме? Функция прогнозирования из svm требует в качестве входных данных набор данных и не принимает поток данных. К сожалению, я не могу...