org.apache.spark.mllib.linalg.distributed

Class IndexedRowMatrix

java.lang.Object

org.apache.spark.mllib.linalg.distributed.IndexedRowMatrix

All Implemented Interfaces:

java.io.Serializable, DistributedMatrix

public class IndexedRowMatrix
extends java.lang.Object
implements DistributedMatrix

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
IndexedRowMatrix(RDD<IndexedRow> rows)
IndexedRowMatrix(RDD<IndexedRow> rows, long nRows, int nCols)

Method Summary

Methods

Modifier and Type	Method and Description
CoordinateMatrix	columnSimilarities()
Matrix	computeGramianMatrix()
SingularValueDecomposition<IndexedRowMatrix,Matrix>	computeSVD(int k, boolean computeU, double rCond)
IndexedRowMatrix	multiply(Matrix B)
long	numCols() Gets or computes the number of columns.
long	numRows() Gets or computes the number of rows.
RDD<IndexedRow>	rows()
BlockMatrix	toBlockMatrix()
BlockMatrix	toBlockMatrix(int rowsPerBlock, int colsPerBlock)
CoordinateMatrix	toCoordinateMatrix()
RowMatrix	toRowMatrix()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

IndexedRowMatrix

public IndexedRowMatrix(RDD<IndexedRow> rows,
                long nRows,
                int nCols)

IndexedRowMatrix

public IndexedRowMatrix(RDD<IndexedRow> rows)

Method Detail

rows

public RDD<IndexedRow> rows()

numCols

public long numCols()

Description copied from interface: DistributedMatrix

Gets or computes the number of columns.

Specified by:

numCols in interface DistributedMatrix

numRows

public long numRows()

Description copied from interface: DistributedMatrix

Gets or computes the number of rows.

Specified by:

numRows in interface DistributedMatrix

columnSimilarities

public CoordinateMatrix columnSimilarities()

toRowMatrix

public RowMatrix toRowMatrix()

toBlockMatrix

public BlockMatrix toBlockMatrix()

toBlockMatrix

public BlockMatrix toBlockMatrix(int rowsPerBlock,
                        int colsPerBlock)

toCoordinateMatrix

public CoordinateMatrix toCoordinateMatrix()

computeSVD

public SingularValueDecomposition<IndexedRowMatrix,Matrix> computeSVD(int k,
                                                             boolean computeU,
                                                             double rCond)

multiply

public IndexedRowMatrix multiply(Matrix B)

computeGramianMatrix

public Matrix computeGramianMatrix()