pegasus.mapreduce.common.cache

Class BaseMatrixIterator<V extends org.apache.hadoop.io.Writable>

java.lang.Object

pegasus.mapreduce.common.cache.BaseMatrixIterator<V>

Type Parameters:

V - The type parameter of matrix elements

All Implemented Interfaces:

java.lang.AutoCloseable, MatrixIterator<V>

public abstract class BaseMatrixIterator<V extends org.apache.hadoop.io.Writable>
extends java.lang.Object
implements MatrixIterator<V>

Iterates over all elements in the given matrix block.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.esotericsoftware.kryo.io.KryoDataInput	dataIn
protected com.esotericsoftware.kryo.io.Input	in

Constructor Summary

Constructors

Constructor and Description
BaseMatrixIterator(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	close()

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.MatrixIterator

currentCol, currentRows, next, numNonzeros

Field Detail

in

protected final com.esotericsoftware.kryo.io.Input in

dataIn

protected final com.esotericsoftware.kryo.io.KryoDataInput dataIn

Constructor Detail

BaseMatrixIterator

public BaseMatrixIterator(org.apache.hadoop.fs.Path path,
                          org.apache.hadoop.conf.Configuration conf)
                   throws java.io.IOException

Throws:

java.io.IOException

Method Detail

close

public void close()
           throws java.lang.Exception

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.lang.Exception