Я пытаюсь разработать модель K-средних во Flink (Scala), используя Zeppelin. Это часть моего простого кода: //Reading data val mapped : DataSet[Vector] = data.map {x => DenseVector (x._1,x._2) } //Create algorithm val knn = KNN() .setK(3)...

В настоящее время я разрабатываю приложение для потоковой обработки, одна из функций которого - принимать события, которые происходят в часовом поясе [время отправки задания, время отправки задания + T]. как получить доступ к этой конкретной...