org.apache.spark.mllib.linalg.distributed

Class CoordinateMatrix

java.lang.Object

org.apache.spark.mllib.linalg.distributed.CoordinateMatrix

All Implemented Interfaces:

java.io.Serializable, DistributedMatrix

public class CoordinateMatrix
extends java.lang.Object
implements DistributedMatrix

Represents a matrix in coordinate format.

param: entries matrix entries param: nRows number of rows. A non-positive value means unknown, and then the number of rows will be determined by the max row index plus one. param: nCols number of columns. A non-positive value means unknown, and then the number of columns will be determined by the max column index plus one.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CoordinateMatrix(RDD<MatrixEntry> entries) Alternative constructor leaving matrix dimensions to be determined automatically.
CoordinateMatrix(RDD<MatrixEntry> entries, long nRows, long nCols)

Method Summary

Methods

Modifier and Type	Method and Description
RDD<MatrixEntry>	entries()
long	numCols() Gets or computes the number of columns.
long	numRows() Gets or computes the number of rows.
BlockMatrix	toBlockMatrix() Converts to BlockMatrix.
BlockMatrix	toBlockMatrix(int rowsPerBlock, int colsPerBlock) Converts to BlockMatrix.
IndexedRowMatrix	toIndexedRowMatrix() Converts to IndexedRowMatrix.
RowMatrix	toRowMatrix() Converts to RowMatrix, dropping row indices after grouping by row index.
CoordinateMatrix	transpose() Transposes this CoordinateMatrix.

Methods inherited from class java.lang.Object

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

Constructor Detail

CoordinateMatrix

public CoordinateMatrix(RDD<MatrixEntry> entries,
                long nRows,
                long nCols)

CoordinateMatrix

public CoordinateMatrix(RDD<MatrixEntry> entries)

Alternative constructor leaving matrix dimensions to be determined automatically.

Method Detail

entries

public RDD<MatrixEntry> entries()

numCols

public long numCols()

Gets or computes the number of columns.

Specified by:

numCols in interface DistributedMatrix

numRows

public long numRows()

Gets or computes the number of rows.

Specified by:

numRows in interface DistributedMatrix

transpose

public CoordinateMatrix transpose()

Transposes this CoordinateMatrix.

toIndexedRowMatrix

public IndexedRowMatrix toIndexedRowMatrix()

Converts to IndexedRowMatrix. The number of columns must be within the integer range.

toRowMatrix

public RowMatrix toRowMatrix()

Converts to RowMatrix, dropping row indices after grouping by row index. The number of columns must be within the integer range.

Returns:

(undocumented)

toBlockMatrix

public BlockMatrix toBlockMatrix()

Converts to BlockMatrix. Creates blocks of SparseMatrix with size 1024 x 1024.

toBlockMatrix

public BlockMatrix toBlockMatrix(int rowsPerBlock,
                        int colsPerBlock)

Converts to BlockMatrix. Creates blocks of SparseMatrix.

Parameters:

rowsPerBlock - The number of rows of each block. The blocks at the bottom edge may have a smaller value. Must be an integer value greater than 0.

colsPerBlock - The number of columns of each block. The blocks at the right edge may have a smaller value. Must be an integer value greater than 0.

Returns:

a BlockMatrix