scala error：コンストラクタを予期した型にインスタンス化できません。

Question

私はスカラーで2つの大きな行列の行列乗算のためにこれをしようとしています。以下は、乗算のための論理です：

​​

M_とN_は、この2つのクラスの2 RDDSです：

case class M_Matrix (i: Long, j: Long, v: Double) 
case class N_Matrix (j: Long, k: Long, w: Double) 

しかし、私は次のエラーを取得しています：

Error image-Please open

私はここで間違って何をしていますか？

Answer 1

rdd/dataframeにはM_MatrixとN_Matrixオブジェクトが含まれているため、タプルと一致させることはできません。このような何か作業をする必要があります：

val res = M_.map(M_ => (M_.j,M_)) 
    .join(N_.map(N_ => (N_.j, N_))) 
    .map{ case (_, (m_matrix, n_matrix)) => ((m_matrix.i, n_matrix.k), m_matrix.v * n_matrix.w)} 
    .reduceByKey(_ + _) 
    .map{ case ((i, k), sum) => (i, k, sum)} 

が

---

電子しまうケースクラスを使用するよりも、よりよい解決策がMatrixEntryを使用する：RDDSを構築する際

import org.apache.spark.mllib.linalg.distributed.MatrixEntry 

M_MatrixとN_Matrixの代わりにそれを使用して、その後、 joinは次のようになります。

val res = M_.map(M_ => (M_.j,M_)) 
    .join(N_.map(N_ => (N_.i, N_))) 
    .map{ case (_, (m_matrix, n_matrix)) => ((m_matrix.i, n_matrix.j), m_matrix.value * n_matrix.value)} 
    .reduceByKey(_ + _) 
    .map{ case ((i, k), sum) => MatrixEntry(i, k, sum)} 

これにより、参加した2人と同じRDD[MatrixEntry]になります。