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 Summary

Constructors

Constructor and Description
IndexedStreamColumnStore(Codec codec, File dataFile, File indexFile) Constructor.

Method Summary

Modifier and Type	Method and Description
void	acceptCell(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

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 Detail

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