Package uk.ac.starlink.table.storage

Class IndexedStreamColumnStore

java.lang.Object
uk.ac.starlink.table.storage.IndexedStreamColumnStore
All Implemented Interfaces:
ColumnStore
public class IndexedStreamColumnStore extends Object implements ColumnStore
ColumnStore implementation which uses two streamed files to store a variable number of variable-length data items.
Since:
21 Jun 2006
Author:
Mark Taylor

  • Constructor Details

    • IndexedStreamColumnStore

      public IndexedStreamColumnStore(Codec codec, File dataFile, File indexFile) throws IOException
      Constructor.
      Parameters:
      codec - encoder/decoder for the type of data stored in this column
      dataFile - filename used for storing the data; it is the caller's responsibility to clear this up
      indexFile - filename used for storing offset values; it is the caller's responsibility to clear this up
      Throws:
      IOException

  • Method Details

    • acceptCell

      public void acceptCell(Object value) throws IOException
      Description copied from interface: ColumnStore
      Writes a datum to this store.
      Specified by:
      acceptCell in interface ColumnStore
      Parameters:
      value - the value to add
      Throws:
      IOException

    • endCells

      public void endCells() throws IOException
      Description copied from interface: ColumnStore
      Signals that no more calls to acceptCell will be made, and that calls to createReader may be made.
      Specified by:
      endCells in interface ColumnStore
      Throws:
      IOException

    • createReader

      public ColumnReader createReader()
      Description copied from interface: ColumnStore
      Returns an object that can provide random access to the cells written to this store.
      Specified by:
      createReader in interface ColumnStore
      Returns:
      column cell reader