alluxio.underfs.s3a

Class S3APositionReader

java.lang.Object

alluxio.underfs.ObjectPositionReader

alluxio.underfs.s3a.S3APositionReader

All Implemented Interfaces:

PositionReader, Closeable, AutoCloseable

@ThreadSafe
public class S3APositionReader
extends ObjectPositionReader

Implementation of ObjectPositionReader that reads from S3A object store.

Field Summary

Fields

Modifier and Type	Field and Description
protected com.amazonaws.services.s3.AmazonS3	mClient Client for operations with s3.

Fields inherited from class alluxio.underfs.ObjectPositionReader

mBucketName, mFileLength, mPath

Constructor Summary

Constructors

Constructor and Description
S3APositionReader(com.amazonaws.services.s3.AmazonS3 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.amazonaws.services.s3.AmazonS3 mClient

Client for operations with s3.

Constructor Detail

S3APositionReader

public S3APositionReader(com.amazonaws.services.s3.AmazonS3 client,
                         String bucketName,
                         String path,
                         long fileLength)

Parameters:

client - the amazon s3a 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