alluxio.underfs.gcs

Class GCSPositionReader

java.lang.Object

alluxio.underfs.ObjectPositionReader

alluxio.underfs.gcs.GCSPositionReader

All Implemented Interfaces:

PositionReader, Closeable, AutoCloseable

@ThreadSafe
public class GCSPositionReader
extends ObjectPositionReader

Implementation of ObjectPositionReader that reads from GCS object store.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.jets3t.service.impl.rest.httpclient.GoogleStorageService	mClient Client for operations with Aliyun OSS.

Fields inherited from class alluxio.underfs.ObjectPositionReader

mBucketName, mFileLength, mPath

Constructor Summary

Constructors

Constructor and Description
GCSPositionReader(org.jets3t.service.impl.rest.httpclient.GoogleStorageService 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 org.jets3t.service.impl.rest.httpclient.GoogleStorageService mClient

Client for operations with Aliyun OSS.

Constructor Detail

GCSPositionReader

public GCSPositionReader(org.jets3t.service.impl.rest.httpclient.GoogleStorageService 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)

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