alluxio.underfs.cos

Class COSPositionReader

java.lang.Object

alluxio.underfs.ObjectPositionReader

alluxio.underfs.cos.COSPositionReader

All Implemented Interfaces:

PositionReader, Closeable, AutoCloseable

@ThreadSafe
public class COSPositionReader
extends ObjectPositionReader

Implementation of ObjectPositionReader that reads from COS object store.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.qcloud.cos.COSClient	mClient Client for operations with COS.

Fields inherited from class alluxio.underfs.ObjectPositionReader

mBucketName, mFileLength, mPath

Constructor Summary

Constructors

Constructor and Description
COSPositionReader(com.qcloud.cos.COSClient 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.qcloud.cos.COSClient mClient

Client for operations with COS.

Constructor Detail

COSPositionReader

public COSPositionReader(com.qcloud.cos.COSClient client,
                         String bucketName,
                         String path,
                         long fileLength)

Parameters:

client - the Tencent COS 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