Spark 1.6.0 DenseMatrix 更新值

Question

Spark 1.3.1 中有 Update 方法

https://spark.apache.org/docs/1.3.1/api/java/org/apache/spark/mllib/linalg/DenseMatrix.html

但是在Spark 1.6.0中，没有Update方法

https://spark.apache.org/docs/1.6.0/api/java/org/apache/spark/mllib/linalg/DenseMatrix.html

我的想法是将大量元素存储在分布式矩阵中并对其执行操作，如何更新 DenseMatrix 中的值？

欢迎任何示例或建议！

Answer 1

1. org.apache.spark.mllib.linalg.DenseMatrix - 不是分布式数据结构，而是本地数据结构，使用纯 Java 数组实现。如果您正在寻找可以有效更新的本地数据结构，请考虑使用Breeze
2. 分布式矩阵 (mllib.linalg.distributed.DistributedMatrix) 与 Spark 中的其他分布式数据结构一样，是不可变的。