Package nz.org.riskscape.engine.io

Interface TupleStorage

public interface TupleStorage

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

  • 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