Следующий код является ответом на этот вопрос: Обнаружение аномалий с помощью PCA в Spark import...

У меня есть Rdd[(Int, BreezeDenseMatrix)] и Rdd[(Int, BreezeDenseMatrix)], которые я хочу...