pyspark.mllib DenseMatrixの乗算

Question

私はpysparkで行列の乗算を行う必要がありますが、DenseMatrixで行う方法は見つけられません。次のエラーで例えば

from pyspark.mllib.linalg import DenseMatrix 
    Q = DenseMatrix(nfeatures, nfeatures, [1, 0, 0, 0, 1, 0, 0, 0, 1]) 
    w = DenseMatrix(nfeatures, 1, [0, 0, 0]) 
    print(Q * w) 

結果：私が間違っているのは何

TypeError: unsupported operand type(s) for *: 'DenseMatrix' and 'DenseMatrix' 

？行列の乗算を行う方法はありますか？ pysparkストリーミングでこれを行う通常の方法は何ですか？

ご迷惑をおかけして申し訳ありません。

敬具、 ノエリア

Answer 1

pyspark.ml.linalg.Matrixもpyspark.mllib.linalg.Matrixどちらも行列の乗算を実装しています。これらのクラスは、ほとんどがmllib/mlアルゴリズムの交換フォーマットとして使用され、線形代数の完全なデータ構造として使用するようには設計されていません。

ML/MLlibアルゴリズムにデータを渡す以上のものが必要な場合は、標準のNumPy/SciPyスタックを使用してください。