diff options
author | MechCoder <manojkumarsivaraj334@gmail.com> | 2015-04-09 23:10:13 -0700 |
---|---|---|
committer | Xiangrui Meng <meng@databricks.com> | 2015-04-09 23:10:13 -0700 |
commit | e2360810f50de77f79d372cc9b46db117d451cfc (patch) | |
tree | 7a0d651141c4149fe36dd2276c66f5ab2214185f /python/pyspark/streaming/kafka.py | |
parent | b5c51c8df480f1a82a82e4d597d8eea631bffb4e (diff) | |
download | spark-e2360810f50de77f79d372cc9b46db117d451cfc.tar.gz spark-e2360810f50de77f79d372cc9b46db117d451cfc.tar.bz2 spark-e2360810f50de77f79d372cc9b46db117d451cfc.zip |
[SPARK-6577] [MLlib] [PySpark] SparseMatrix should be supported in PySpark
Supporting of SparseMatrix in PySpark.
Author: MechCoder <manojkumarsivaraj334@gmail.com>
Closes #5355 from MechCoder/spark-6577 and squashes the following commits:
7492190 [MechCoder] More readable code for densifying
ea2c54b [MechCoder] Check bounds for indexing
454ef2c [MechCoder] Made the following changes 1. Used convert_to_array for array conversion. 2. Used F order for toArray 3. Minor improvements in speed.
db76caf [MechCoder] Add support for CSR matrix
29653e7 [MechCoder] Renamed indices to rowIndices and indptr to colPtrs
b6384fe [MechCoder] [SPARK-6577] SparseMatrix should be supported in PySpark
Diffstat (limited to 'python/pyspark/streaming/kafka.py')
0 files changed, 0 insertions, 0 deletions