alluxio.underfs.obs

Class OBSInputStream

java.lang.Object

java.io.InputStream

alluxio.underfs.MultiRangeObjectInputStream

alluxio.underfs.obs.OBSInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

@NotThreadSafe
public class OBSInputStream
extends MultiRangeObjectInputStream

A stream for reading a file from OBS. This input stream returns 0 when calling read with an empty buffer.

Field Summary

Fields inherited from class alluxio.underfs.MultiRangeObjectInputStream

mClosed, mEndPos, mPos, mStream

Method Summary

Modifier and Type	Method and Description
protected InputStream	createStream(long startPos, long endPos) Opens a new stream reading a range.

Methods inherited from class alluxio.underfs.MultiRangeObjectInputStream

close, read, read, read, skip

Methods inherited from class java.io.InputStream

available, mark, markSupported, reset

Methods inherited from class java.lang.Object

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

Method Detail

createStream

protected InputStream createStream(long startPos,
                                   long endPos)
                            throws IOException

Description copied from class: MultiRangeObjectInputStream

Opens a new stream reading a range. When endPos > content length, the returned stream should read till the last valid byte of the input. The behaviour is undefined when (startPos < 0), (startPos >= content length), or (endPos <= 0).

Specified by:

createStream in class MultiRangeObjectInputStream

Parameters:

startPos - start position in bytes (inclusive)

endPos - end position in bytes (exclusive)

Returns:

a new InputStream

Throws:

IOException