alluxio.proxy.s3

Class S3BaseTask

java.lang.Object

alluxio.proxy.s3.S3BaseTask

Direct Known Subclasses:

S3BucketTask, S3ObjectTask

public abstract class S3BaseTask
extends Object

S3 Abstract Base task for handling S3 API logic.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	S3BaseTask.OpTag Enum for tagging the http request to target for different threadpools for handling.
static class	S3BaseTask.OpType Enum indicating name of S3 API handling per http request.

Field Summary

Fields

Modifier and Type	Field and Description
protected S3Handler	mHandler
protected S3BaseTask.OpType	mOPType

Constructor Summary

Constructors

Constructor and Description
S3BaseTask(S3Handler handler, S3BaseTask.OpType opType) Instantiate a S3BaseTask.

Method Summary

Modifier and Type	Method and Description
abstract javax.ws.rs.core.Response	continueTask() Run core S3 API logic from different S3 task.
S3BaseTask.OpType	getOPType() Return the OpType (S3 API enum).
void	handleTaskAsync() Run S3 API logic in a customized async way, e.g.

Methods inherited from class java.lang.Object

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

Field Detail

mHandler

protected S3Handler mHandler

mOPType

protected S3BaseTask.OpType mOPType

Constructor Detail

S3BaseTask

public S3BaseTask(S3Handler handler,
                  S3BaseTask.OpType opType)

Instantiate a S3BaseTask.

Parameters:

handler - S3Handler object

opType - the enum indicate the S3 API name

Method Detail

getOPType

public S3BaseTask.OpType getOPType()

Return the OpType (S3 API enum).

Returns:

OpType (S3 API enum)

continueTask

public abstract javax.ws.rs.core.Response continueTask()

Run core S3 API logic from different S3 task.

Returns:

Response object containing common HTTP response properties

handleTaskAsync

public void handleTaskAsync()

Run S3 API logic in a customized async way, e.g. delegate the core API logic to another thread and do something while waiting.