Package nz.org.riskscape.engine.io

Class DiskStorageReader

java.lang.Object

nz.org.riskscape.engine.io.DiskStorageReader

All Implemented Interfaces:

Closeable, AutoCloseable, nz.org.riskscape.engine.io.TupleReader

public class DiskStorageReader
extends Object
implements nz.org.riskscape.engine.io.TupleReader

Wraps a DataInputStreamTupleReader to apply byte counting and buffering to a FileOutputStream.

Constructor Summary

Constructors

Constructor	Description
DiskStorageReader(File file, boolean compressed)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getBytesRead()
File	getFile()
nz.org.riskscape.engine.Tuple	read(nz.org.riskscape.engine.types.Struct expected)

Methods inherited from class java.lang.Object

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

Methods inherited from interface nz.org.riskscape.engine.io.TupleReader

forEach

Constructor Details

DiskStorageReader

public DiskStorageReader(File file,
 boolean compressed)
                  throws IOException

Throws:

IOException

Method Details

read

public nz.org.riskscape.engine.Tuple read(nz.org.riskscape.engine.types.Struct expected)
                                   throws IOException

Specified by:

read in interface nz.org.riskscape.engine.io.TupleReader

Throws:

IOException

getBytesRead

public long getBytesRead()

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getFile

public File getFile()