pyspark rddにcsc_matrixをロードする方法

Question

RDDにロードする必要があるスパースcsc_matrixがあります。しかし、RDD はサポートなどcsc_matrixの直接ロードされていません。

sc.parallelize(my_csc_matrix) 

たちはRDDフレンドリースパースベクトルにcsc_matrixを変換することができます方法はありますか？

Answer 1

あなたが使用してRDDにロードすることができます。

rdd = sc.parallelize(my_csc_matrix.toarray()) 

が、この方法をロードすることによって、あなたは再び高密度アレイにあなたのcsc_matrixを変換してからロードしているが。しかし、とにかく上記のコードを使用してロードすることができます。