Package com.attivio.util.ft

Class FileTransactionStorage.FileInput

java.lang.Object

java.io.InputStream

com.attivio.util.ft.TransactionStorage.TransactionInput

com.attivio.util.ft.FileTransactionStorage.FileInput

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

FileTransactionStorage

protected class FileTransactionStorage.FileInput
extends TransactionStorage.TransactionInput

Constructor Summary

Constructors

Constructor	Description
FileInput(java.io.File path)

Method Summary

Modifier and Type	Method	Description
void	close()
long	getPos()
protected byte	readByte()
protected void	readBytes(byte[] buffer, int offset, int length)
protected int	readInt()
protected int	readUnsignedShort()
protected void	seekInternal(long pos)
java.lang.String	toString()

Methods inherited from class com.attivio.util.ft.TransactionStorage.TransactionInput

read, readDocument, readFrameId, readId, readMessageId, readObject, readString, reset, seek, sync

Methods inherited from class java.io.InputStream

available, mark, markSupported, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, skip, transferTo

Methods inherited from class java.lang.Object

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

Constructor Detail

FileInput

public FileInput(java.io.File path)
          throws java.io.IOException

Throws:

java.io.IOException

Method Detail

getPos

public long getPos()
            throws java.io.IOException

Specified by:

getPos in class TransactionStorage.TransactionInput

Throws:

java.io.IOException

seekInternal

protected void seekInternal(long pos)
                     throws java.io.IOException

Specified by:

seekInternal in class TransactionStorage.TransactionInput

Throws:

java.io.IOException

readBytes

protected void readBytes(byte[] buffer,
                         int offset,
                         int length)
                  throws java.io.IOException

Specified by:

readBytes in class TransactionStorage.TransactionInput

Throws:

java.io.IOException

readUnsignedShort

protected int readUnsignedShort()
                         throws java.io.IOException

Specified by:

readUnsignedShort in class TransactionStorage.TransactionInput

Throws:

java.io.IOException

readInt

protected int readInt()
               throws java.io.IOException

Specified by:

readInt in class TransactionStorage.TransactionInput

Throws:

java.io.IOException

readByte

protected byte readByte()
                 throws java.io.IOException

Specified by:

readByte in class TransactionStorage.TransactionInput

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Overrides:

close in class java.io.InputStream

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object