Class StreamColumnStore

  • All Implemented Interfaces:
    ColumnStore

    public class StreamColumnStore
    extends java.lang.Object
    implements ColumnStore
    ColumnStore implementation which uses a streamed file to store a variable number of fixed-length data items.
    Since:
    21 Jun 2006
    Author:
    Mark Taylor
    • Constructor Summary

      Constructors 
      Constructor Description
      StreamColumnStore​(Codec codec, java.io.File dataFile)
      Constructor.
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void acceptCell​(java.lang.Object value)
      Writes a datum to this store.
      ColumnReader createReader()
      Returns an object that can provide random access to the cells written to this store.
      void endCells()
      Signals that no more calls to acceptCell will be made, and that calls to createReader may be made.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • StreamColumnStore

        public StreamColumnStore​(Codec codec,
                                 java.io.File dataFile)
                          throws java.io.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
        Throws:
        java.io.IOException
    • Method Detail

      • acceptCell

        public void acceptCell​(java.lang.Object value)
                        throws java.io.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:
        java.io.IOException
      • endCells

        public void endCells()
                      throws java.io.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:
        java.io.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