pegasus.mapreduce.common.cache

Class BaseMatrixCache<M extends org.apache.hadoop.io.Writable>

java.lang.Object

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

Type Parameters:

M - The type parameter of matrix values

All Implemented Interfaces:

MatrixCache<M>

Direct Known Subclasses:

UnweightedMatrixCache, WeightedMatrixCache

public abstract class BaseMatrixCache<M extends org.apache.hadoop.io.Writable>
extends java.lang.Object
implements MatrixCache<M>

Represents a matrix block contains matrix elements.

Field Summary

Fields

Modifier and Type	Field and Description
protected IntIntPairWritable	col
protected it.unimi.dsi.fastutil.ints.IntArrayList	colList
protected org.apache.hadoop.conf.Configuration	conf
protected it.unimi.dsi.fastutil.ints.IntArrayList	degrees
protected org.apache.hadoop.fs.Path	path
protected it.unimi.dsi.fastutil.ints.IntArrayList	rowList
protected it.unimi.dsi.fastutil.ints.IntArrayList	rowSizes

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseMatrixCache(java.lang.String blockName, org.apache.hadoop.conf.Configuration conf, int numCols, int numRows, int sizePerValue)

Method Summary

Modifier and Type	Method and Description
void	freeze()
void	put(IntIntPairWritable col, M rows)
protected abstract void	putToMemory(IntIntPairWritable col, M rows)

Methods inherited from class java.lang.Object

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

Methods inherited from interface pegasus.mapreduce.common.cache.MatrixCache

iterator

Field Detail

conf

protected final org.apache.hadoop.conf.Configuration conf

colList

protected final it.unimi.dsi.fastutil.ints.IntArrayList colList

rowList

protected final it.unimi.dsi.fastutil.ints.IntArrayList rowList

rowSizes

protected final it.unimi.dsi.fastutil.ints.IntArrayList rowSizes

degrees

protected final it.unimi.dsi.fastutil.ints.IntArrayList degrees

path

protected final org.apache.hadoop.fs.Path path

col

protected final IntIntPairWritable col

Constructor Detail

BaseMatrixCache

protected BaseMatrixCache(java.lang.String blockName,
                          org.apache.hadoop.conf.Configuration conf,
                          int numCols,
                          int numRows,
                          int sizePerValue)
                   throws java.io.IOException

Throws:

java.io.IOException

Method Detail

put

public void put(IntIntPairWritable col,
                M rows)
         throws java.io.IOException

Specified by:

put in interface MatrixCache<M extends org.apache.hadoop.io.Writable>

Throws:

java.io.IOException

putToMemory

protected abstract void putToMemory(IntIntPairWritable col,
                                    M rows)

freeze

public void freeze()

Specified by:

freeze in interface MatrixCache<M extends org.apache.hadoop.io.Writable>