alluxio.underfs.obs

Class OBSPositionReader

java.lang.Object

alluxio.underfs.ObjectPositionReader

alluxio.underfs.obs.OBSPositionReader

All Implemented Interfaces:

PositionReader, Closeable, AutoCloseable

public class OBSPositionReader
extends ObjectPositionReader

Implementation of ObjectPositionReader that reads from OBS object store.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.obs.services.ObsClient	mClient Client for operations with OBS.

Fields inherited from class alluxio.underfs.ObjectPositionReader

mBucketName, mFileLength, mPath

Constructor Summary

Constructors

Constructor and Description
OBSPositionReader(com.obs.services.ObsClient client, String bucketName, String path, long fileLength)

Method Summary

Modifier and Type	Method and Description
protected InputStream	openObjectInputStream(long position, int bytesToRead)

Methods inherited from class alluxio.underfs.ObjectPositionReader

readInternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.PositionReader

close, read, read, read, read, read

Field Detail

mClient

protected final com.obs.services.ObsClient mClient

Client for operations with OBS.

Constructor Detail

OBSPositionReader

public OBSPositionReader(com.obs.services.ObsClient client,
                         String bucketName,
                         String path,
                         long fileLength)

Parameters:

client - the OBS client

bucketName - the bucket name

path - the file path

fileLength - the file length

Method Detail

openObjectInputStream

protected InputStream openObjectInputStream(long position,
                                            int bytesToRead)
                                     throws IOException

Specified by:

openObjectInputStream in class ObjectPositionReader

Parameters:

position - position of the file to start reading data

bytesToRead - bytes to read

Returns:

input stream of Object Storage's API

Throws:

IOException