val ent1 = new MatrixEntry(0, 1, 0.5) val ent2 = new MatrixEntry(2, 2, 1.8) val dataRDD = sc.parallelize(Array(ent1, ent2)) val CorrMat = new CoordinateMatrix(dataRDD)

这段代码使用了 Spark MLlib 中的 CoordinateMatrix 工具，创建了一个坐标矩阵 CorrMat，其中包含两个元素 (0, 1, 0.5) 和 (2, 2, 1.8)。这两个元素分别表示矩阵的第 1 行第 2 列的元素值为 0.5，以及矩阵的第 3 行第 3 列的元素值为 1.8。注意，MatrixEntry 是 CoordinateMatrix 中的一个类，用于表示矩阵中的一个元素，它包含三个属性：行坐标、列坐标和元素值。通过 sc.parallelize(Array(ent1, ent2)) 创建一个 RDD 对象 dataRDD，然后使用 dataRDD 创建 CorrMat。最终得到的 CorrMat 是一个 3x3 的矩阵，除 (0, 1) 和 (2, 2) 外，其余元素都为 0。