Package nz.org.riskscape.engine.io

Class DiskStorageWriter

java.lang.Object

nz.org.riskscape.engine.io.DiskStorageWriter

All Implemented Interfaces:

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

public class DiskStorageWriter
extends Object
implements nz.org.riskscape.engine.io.TupleWriter, Closeable

Wraps a DataOutputStreamTupleWriter to write out to a buffered and byte counted FileOutputStream.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BUFFER_SIZE
static final long	OUT_OF_DISK_THRESHOLD_BYTES

Constructor Summary

Constructors

Constructor	Description
DiskStorageWriter(File file, boolean compressed)
DiskStorageWriter(File file, boolean compressed, com.codahale.metrics.Counter metricsCounter)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getBytesWritten()
File	getFile()
void	remove()
void	write(nz.org.riskscape.engine.Tuple tuple)

Methods inherited from class java.lang.Object

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

Field Details

BUFFER_SIZE

public static final int BUFFER_SIZE

See Also:

• Constant Field Values

OUT_OF_DISK_THRESHOLD_BYTES

public static final long OUT_OF_DISK_THRESHOLD_BYTES

See Also:

• Constant Field Values

Constructor Details

DiskStorageWriter

public DiskStorageWriter(File file,
 boolean compressed)
                  throws IOException

Throws:

IOException

DiskStorageWriter

public DiskStorageWriter(File file,
 boolean compressed,
 com.codahale.metrics.Counter metricsCounter)
                  throws IOException

Throws:

IOException

Method Details

write

public void write(nz.org.riskscape.engine.Tuple tuple)
           throws IOException

Specified by:

write in interface nz.org.riskscape.engine.io.TupleWriter

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

remove

public void remove()
            throws IOException

Specified by:

remove in interface nz.org.riskscape.engine.io.TupleWriter

Throws:

IOException

getBytesWritten

public long getBytesWritten()
                     throws IOException

Returns:

the number of bytes written to the buffer so far.

Throws:

IOException

getFile

public File getFile()