Package org.apache.iotdb.tsfile.read.reader

Class LocalTsFileInput

java.lang.Object

org.apache.iotdb.tsfile.read.reader.LocalTsFileInput

All Implemented Interfaces:

TsFileInput

public class LocalTsFileInput
extends Object
implements TsFileInput

Constructor Summary

Constructors

Constructor	Description
LocalTsFileInput(Path file)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this channel.
String	getFilePath()
long	position()	Returns this input's current position.
TsFileInput	position(long newPosition)	Sets this input's position.
int	read(ByteBuffer dst)	Reads a sequence of bytes from this TsFileInput into the given buffer.
int	read(ByteBuffer dst, long position)	Reads a sequence of bytes from this TsFileInput into the given buffer, starting at the given position.
long	size()	Returns the current size of this input.
InputStream	wrapAsInputStream()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iotdb.tsfile.read.reader.TsFileInput

readVarIntString

Constructor Detail

LocalTsFileInput

public LocalTsFileInput(Path file)
                 throws IOException

Throws:

IOException

Method Detail

size

public long size()
          throws IOException

Description copied from interface: TsFileInput

Returns the current size of this input.

Specified by:

size in interface TsFileInput

Returns:

The current size of this input, measured in bytes

Throws:

ClosedChannelException - If this channel is closed

IOException - If some other I/O error occurs

position

public long position()
              throws IOException

Description copied from interface: TsFileInput

Returns this input's current position.

Specified by:

position in interface TsFileInput

Returns:

This input's current position, a non-negative integer counting the number of bytes from the beginning of the input to the current position

Throws:

ClosedChannelException - If this input is closed

IOException - If some other I/O error occurs

position

public TsFileInput position(long newPosition)
                     throws IOException

Description copied from interface: TsFileInput

Sets this input's position.

Setting the position to a value that is greater than the input's current size is legal but does not change the size of the TsFileInput. A later attempt to read bytes at such a position will immediately return an end-of-file indication.

Specified by:

position in interface TsFileInput

Parameters:

newPosition - The new position, a non-negative integer counting the number of bytes from the beginning of the TsFileInput

Returns:

This TsFileInput

Throws:

ClosedChannelException - If this TsFileInput is closed

IOException - If some other I/O error occurs

read

public int read(ByteBuffer dst)
         throws IOException

Description copied from interface: TsFileInput

Reads a sequence of bytes from this TsFileInput into the given buffer.

Bytes are read starting at this TsFileInput's current position, and then the position is updated with the number of bytes actually read. Otherwise this method behaves exactly as specified in the ReadableByteChannel interface.

Specified by:

read in interface TsFileInput

Throws:

IOException

read

public int read(ByteBuffer dst,
                long position)
         throws IOException

Description copied from interface: TsFileInput

Reads a sequence of bytes from this TsFileInput into the given buffer, starting at the given position.

This method works in the same manner as the TsFileInput.read(ByteBuffer) method, except that bytes are read starting at the given position rather than at the TsFileInput's current position. This method does not modify this TsFileInput's position. If the given position is greater than the TsFileInput's current size then no bytes are read.

Specified by:

read in interface TsFileInput

Parameters:

dst - The buffer into which bytes are to be transferred

position - The position at which the transfer is to begin; must be non-negative

Returns:

The number of bytes read, possibly zero, or -1 if the given position is greater than or equal to the file's current size

Throws:

ClosedChannelException - If this TsFileInput is closed

AsynchronousCloseException - If another thread closes this TsFileInput while the read operation is in progress

ClosedByInterruptException - If another thread interrupts the current thread while the read operation is in progress, thereby closing the channel and setting the current thread's interrupt status

IOException - If some other I/O error occurs

wrapAsInputStream

public InputStream wrapAsInputStream()

Specified by:

wrapAsInputStream in interface TsFileInput

close

public void close()
           throws IOException

Description copied from interface: TsFileInput

Closes this channel.

If the channel has already been closed then this method returns immediately.

Specified by:

close in interface TsFileInput

Throws:

IOException - If an I/O error occurs

getFilePath

public String getFilePath()

Specified by:

getFilePath in interface TsFileInput