alluxio.underfs.cephfs

Class CephSeekableInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

alluxio.underfs.SeekableUnderFileInputStream

alluxio.underfs.cephfs.CephSeekableInputStream

All Implemented Interfaces:

Positioned, Seekable, Closeable, AutoCloseable

public class CephSeekableInputStream
extends SeekableUnderFileInputStream

The input stream of CEPHFS as under filesystem. This input stream supports seeking and can be cached for reuse.

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Method Summary

Modifier and Type	Method and Description
long	getPos()
void	seek(long position) Moves the starting read position of the stream to the specified position which is relative to the start of the stream.

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Method Detail

seek

public void seek(long position)
          throws IOException

Description copied from interface: Seekable

Moves the starting read position of the stream to the specified position which is relative to the start of the stream. Seeking to a position before the current read position is supported.

Parameters:

position - the position to seek to, it must be between 0 and the end of the stream - 1

Throws:

IOException

getPos

public long getPos()
            throws IOException

Returns:

the current position

Throws:

IOException