pegasus.mapreduce.common.cache

Class UnweightedMatrixCache

java.lang.Object

pegasus.mapreduce.common.cache.BaseMatrixCache<IntArrayWritable>

pegasus.mapreduce.common.cache.UnweightedMatrixCache

All Implemented Interfaces:

MatrixCache<IntArrayWritable>

public class UnweightedMatrixCache
extends BaseMatrixCache<IntArrayWritable>

Field Summary

Fields inherited from class pegasus.mapreduce.common.cache.BaseMatrixCache

col, colList, conf, degrees, path, rowList, rowSizes

Constructor Summary

Constructors

Constructor and Description
UnweightedMatrixCache(java.lang.String blockName, org.apache.hadoop.conf.Configuration conf, int numCols, int numRows)

Method Summary

Modifier and Type	Method and Description
MatrixIterator<IntArrayWritable>	iterator()
protected void	putToMemory(IntIntPairWritable col, IntArrayWritable rows)

Methods inherited from class pegasus.mapreduce.common.cache.BaseMatrixCache

freeze, put

Methods inherited from class java.lang.Object

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

Constructor Detail

UnweightedMatrixCache

public UnweightedMatrixCache(java.lang.String blockName,
                             org.apache.hadoop.conf.Configuration conf,
                             int numCols,
                             int numRows)
                      throws java.io.IOException

Throws:

java.io.IOException

Method Detail

putToMemory

protected void putToMemory(IntIntPairWritable col,
                           IntArrayWritable rows)

Specified by:

putToMemory in class BaseMatrixCache<IntArrayWritable>

iterator

public MatrixIterator<IntArrayWritable> iterator()
                                          throws java.io.IOException

Throws:

java.io.IOException