com.bigdata.io.writecache

Class BufferedWrite

java.lang.Object

com.bigdata.io.writecache.BufferedWrite

public class BufferedWrite
extends Object

The BufferedWrite merges/elides sorted scattered writes to minimize IO requests and maximize IO rates. This has a net positive effect on SAS, SATA, and SSD.

Author:

Martyn Cutcher

Constructor Summary

Constructors

Constructor and Description
BufferedWrite(IBufferedWriter store)

Method Summary

Methods

Modifier and Type	Method and Description
int	flush(IReopenChannel<FileChannel> opener) Flush buffered data to the backing channel.
String	getStats(StringBuffer buf, boolean reset)
void	release() Release the direct buffer associated with this object.
void	reset() Reset the buffer position and limit and clear the starting offset on the file to -1.
int	write(long offset, ByteBuffer data, IReopenChannel<FileChannel> opener) Buffer a write.

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferedWrite

public BufferedWrite(IBufferedWriter store)
              throws InterruptedException

Throws:

InterruptedException

Method Detail

release

public void release()
             throws InterruptedException

Release the direct buffer associated with this object.

Throws:

InterruptedException

write

public int write(long offset,
        ByteBuffer data,
        IReopenChannel<FileChannel> opener)
          throws IOException

Buffer a write.

Parameters:

offset - The offset on the backing channel at which the data should be written.

data - The data.

opener - The object which knows how to re-open the backing channel.

Returns:

The #of write IOs performed during this method call.

Throws:

IOException

flush

public int flush(IReopenChannel<FileChannel> opener)
          throws IOException

Flush buffered data to the backing channel.

Parameters:

opener - The object which knows how to re-open the backing channel.

Returns:

The #of write IOs performed during this method call.

Throws:

IOException

reset

public void reset()

Reset the buffer position and limit and clear the starting offset on the file to -1.

getStats

public String getStats(StringBuffer buf,
              boolean reset)