pegasus.mapreduce.common.cache

Class WeightedMatrixCache

java.lang.Object

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

pegasus.mapreduce.common.cache.WeightedMatrixCache

All Implemented Interfaces:

MatrixCache<IntDoublePairArrayWritable>

public class WeightedMatrixCache
extends BaseMatrixCache<IntDoublePairArrayWritable>

Field Summary

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

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
MatrixIterator<IntDoublePairArrayWritable>	iterator()
protected void	putToMemory(IntIntPairWritable col, IntDoublePairArrayWritable 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

WeightedMatrixCache

public WeightedMatrixCache(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,
                           IntDoublePairArrayWritable rows)

Specified by:

putToMemory in class BaseMatrixCache<IntDoublePairArrayWritable>

iterator

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

Throws:

java.io.IOException