com.aliyun.odps.volume

类 FSDataInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

java.io.DataInputStream

com.aliyun.odps.volume.FSDataInputStream

所有已实现的接口:

Closeable, DataInput, AutoCloseable

public abstract class FSDataInputStream
extends DataInputStream

DataInputStream with seek and getPos.

构造器概要

构造器

构造器和说明
FSDataInputStream(InputStream in)

方法概要

方法

限定符和类型	方法和说明
abstract long	getPos() Get the current position in the input stream.
abstract int	read(long position, byte[] buffer, int offset, int length) Read bytes from the given position in the stream to the given buffer.
void	readFully(long position, byte[] buffer) See readFully(long, byte[], int, int).
abstract void	readFully(long position, byte[] buffer, int offset, int length) Read bytes from the given position in the stream to the given buffer.
abstract void	seek(long desired) Seek to the given offset.

从类继承的方法 java.io.DataInputStream

read, read, readBoolean, readByte, readChar, readDouble, readFloat, readFully, readFully, readInt, readLine, readLong, readShort, readUnsignedByte, readUnsignedShort, readUTF, readUTF, skipBytes

从类继承的方法 java.io.FilterInputStream

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

从类继承的方法 java.lang.Object

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

构造器详细资料

FSDataInputStream

public FSDataInputStream(InputStream in)
                  throws IOException

抛出:

IOException

方法详细资料

seek

public abstract void seek(long desired)
                   throws IOException

Seek to the given offset.

参数:

desired - offset to seek to

抛出:

IOException

getPos

public abstract long getPos()
                     throws IOException

Get the current position in the input stream.

返回:

current position in the input stream

抛出:

IOException

read

public abstract int read(long position,
       byte[] buffer,
       int offset,
       int length)
                  throws IOException

Read bytes from the given position in the stream to the given buffer.

参数:

position - position in the input stream to seek

buffer - buffer into which data is read

offset - offset into the buffer in which data is written

length - maximum number of bytes to read

返回:

total number of bytes read into the buffer, or -1 if there is no more data because the end of the stream has been reached

抛出:

IOException

readFully

public abstract void readFully(long position,
             byte[] buffer,
             int offset,
             int length)
                        throws IOException

Read bytes from the given position in the stream to the given buffer. Continues to read until length bytes have been read.

参数:

position - position in the input stream to seek

buffer - buffer into which data is read

offset - offset into the buffer in which data is written

length - the number of bytes to read

抛出:

EOFException - If the end of stream is reached while reading. If an exception is thrown an undetermined number of bytes in the buffer may have been written.

IOException

readFully

public void readFully(long position,
             byte[] buffer)
               throws IOException

See readFully(long, byte[], int, int).

抛出:

IOException