У меня есть два Rdd[(Int, BreezeDenseMatrix[Double])]
, и я хочу сравнить их. Скажем, что Rdd_1
равно W
, а Rdd_2
равно threshold
. Когда ids
'совпадают, я хочу проверить condition
:
if (W(::,1) - pow(W(::,0),2) < threshold(::,0))
viol(::, 1)
else
viol(::, 0)
Итак, в качестве вывода Rdd
я хочу получить RDD[(Int, BreezeDenseMatrix[Double])]
, где BreezeDenseMatrix
будет viol
.
Дело в том, что я не могу найти, как сравнивать Breeze
матрицы.
Я попробовал это как начало:
W.join(threshold).map(x=> if (x._2._1(::, 1) - pow(x._2._1(::, 0),2) <:< x._2._2(::,0)){ (x._1, )})
как я обнаружил, <:<
- это оператор Breeze
для сравнения, но я получаю cannot resolve symbol <:<
У кого-нибудь есть идеи?