Package com.illumon.iris.binarystore

Class BinaryStoreReaderV1

java.lang.Object

com.illumon.iris.binarystore.AbstractBinaryStoreReader

com.illumon.iris.binarystore.AbstractBinaryStoreReaderV1

com.illumon.iris.binarystore.BinaryStoreReaderV1

All Implemented Interfaces:

BinaryStoreReader, SkipableTableReader, TableReader

public class BinaryStoreReaderV1
extends AbstractBinaryStoreReaderV1
implements SkipableTableReader

Table reader for Version 1 of the binary store.

Nested Class Summary

Nested classes/interfaces inherited from class com.illumon.iris.binarystore.AbstractBinaryStoreReader

AbstractBinaryStoreReader.MissingGetterException

Nested classes/interfaces inherited from interface com.illumon.iris.binarystore.TableReader

TableReader.MissingPropertyGetterException

Field Summary

Fields inherited from class com.illumon.iris.binarystore.AbstractBinaryStoreReader

columnNames, columnTypes, CONSUMER_BUFFER_SIZE, dataBuffer, mask, PRODUCER_BUFFER_SIZE, rowGetters, typeMetadata

Constructor Summary

Constructors

Constructor	Description
BinaryStoreReaderV1(File path)
BinaryStoreReaderV1(String path)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the input source for this TableReader.
long	getSize()
protected void	readData(int minAmount, ByteBuffer dataBuffer)	If this reader is not in blocking mode, read up to dataBuffer.remaining() bytes and return.
void	seek(long position)
void	setBlocking(boolean blocking)	As implemented, blocking means sleep and retry.
void	skipToRecord(long recordNo)

Methods inherited from class com.illumon.iris.binarystore.AbstractBinaryStoreReaderV1

getApplicationVersion, getFlagGetter, readHeader, readRow

Methods inherited from class com.illumon.iris.binarystore.AbstractBinaryStoreReader

getColumnNames, getColumnType, getGetter, getGetter, getTypeMetadataString, handleRecord, handleRow, readDataBuffer, readHeader, readIntoByteBuffer, setRecordHandler, setRowHandler

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.illumon.iris.binarystore.TableReader

getApplicationVersion, getColumnNames, getColumnType, getFlagGetter, getGetter, getGetter, getPropertyGetter, getRecordDataGetter, readAllEntries, readAllEntries, readEntry, readRow

Constructor Details

BinaryStoreReaderV1

public BinaryStoreReaderV1(@NotNull String path) throws IOException

Throws:

IOException

BinaryStoreReaderV1

public BinaryStoreReaderV1(@NotNull File path) throws IOException

Throws:

IOException

Method Details

setBlocking

public void setBlocking(boolean blocking)

Description copied from interface: SkipableTableReader

As implemented, blocking means sleep and retry.

Specified by:

setBlocking in interface SkipableTableReader

getSize

public long getSize() throws IOException

Specified by:

getSize in interface SkipableTableReader

Throws:

IOException

skipToRecord

public void skipToRecord(long recordNo) throws IOException

Specified by:

skipToRecord in interface SkipableTableReader

Throws:

IOException

seek

public void seek(long position) throws IOException

Throws:

IOException

close

public void close() throws IOException

Description copied from interface: TableReader

Close the input source for this TableReader.

Specified by:

close in interface TableReader

Throws:

IOException

readData

protected void readData(int minAmount, ByteBuffer dataBuffer) throws IOException

If this reader is not in blocking mode, read up to dataBuffer.remaining() bytes and return.

If blocking, read at least minAmount bytes from the input channel. Sleep 1 second between attempts to get more data up to minAmount. Do not acknowledge EOF, hoping more data will appear.

Specified by:

readData in class AbstractBinaryStoreReader

Parameters:

minAmount - don't return without this many bytes (if blocking)

dataBuffer - put the bytes in ths buffer.

Throws:

IOException