Package com.illumon.iris.binarystore

Class BinaryStoreReaderV2

java.lang.Object

com.illumon.iris.binarystore.AbstractBinaryStoreReader

com.illumon.iris.binarystore.AbstractBinaryStoreReaderV2

com.illumon.iris.binarystore.BinaryStoreReaderV2

All Implemented Interfaces:

BinaryStoreReader, SkipableTableReader, TableReader

public class BinaryStoreReaderV2
extends AbstractBinaryStoreReaderV2
implements SkipableTableReader

Table reader for Version 2 of the binary store.

Nested Class Summary

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

AbstractBinaryStoreReaderV2.BinaryStoreRowGetter<T>

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.AbstractBinaryStoreReaderV2

ROW_SIZE_PROP

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
BinaryStoreReaderV2(File path)
BinaryStoreReaderV2(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	setBlocking(boolean blocking)	As implemented, blocking means sleep and retry.
void	skipToRecord(long recordNo)

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

getApplicationVersion, getFlagGetter, getPropertyGetter, getRecordDataGetter, parseRecord, parseRow, readEntry, 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

BinaryStoreReaderV2

public BinaryStoreReaderV2(@NotNull String path) throws IOException

Throws:

IOException

BinaryStoreReaderV2

public BinaryStoreReaderV2(@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

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