alluxio.underfs.oss

Class OSSPositionReader

java.lang.Object

alluxio.underfs.ObjectPositionReader

alluxio.underfs.oss.OSSPositionReader

All Implemented Interfaces:

PositionReader, Closeable, AutoCloseable

@ThreadSafe
public class OSSPositionReader
extends ObjectPositionReader

Implementation of ObjectPositionReader that reads from OSS object store.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.aliyun.oss.OSS	mClient Client for operations with Aliyun OSS.

Fields inherited from class alluxio.underfs.ObjectPositionReader

mBucketName, mFileLength, mPath

Constructor Summary

Constructors

Constructor and Description
OSSPositionReader(com.aliyun.oss.OSS 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.aliyun.oss.OSS mClient

Client for operations with Aliyun OSS.

Constructor Detail

OSSPositionReader

public OSSPositionReader(com.aliyun.oss.OSS client,
                         String bucketName,
                         String path,
                         long fileLength)

Parameters:

client - the Aliyun OSS 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