Package nz.org.riskscape.engine.io

Interface TupleStorage

public interface TupleStorage

Generic, and slightly wip, interface for creating TupleReaders and TupleWriters

Method Summary

Modifier and Type	Method	Description
TupleWriter	createTemporaryWriter()
TupleReader	getReader(TupleWriter writer)

Method Details

createTemporaryWriter

TupleWriter createTemporaryWriter()
                           throws IOException

Returns:

a TupleWriter that is a temporary place to store tuples. So far required for paging large streams out of memory for sorting. Will be deleted sometime in the future.

Throws:

IOException

getReader

TupleReader getReader(TupleWriter writer)
               throws IOException

Parameters:

writer - the writer that we want to read tuples from

Returns:

a TupleReader that will return tuples that were written to the given TupleWriter in the order they were written (FIFO).

Throws:

IOException