com.obs.services.model

Class AbstractBulkRequest

java.lang.Object

com.obs.services.model.GenericRequest

com.obs.services.model.AbstractBulkRequest

Direct Known Subclasses:

DropFolderRequest, PutObjectsRequest, RestoreObjectsRequest

public abstract class AbstractBulkRequest
extends GenericRequest

批量任务请求参数抽象类

Field Summary

Fields

Modifier and Type	Field and Description
protected String	bucketName
protected TaskProgressListener	listener
protected int	taskProgressInterval
protected int	taskQueueNum
protected int	taskThreadNum

Constructor Summary

Constructors

Constructor and Description
AbstractBulkRequest()
AbstractBulkRequest(String bucketName)

Method Summary

Modifier and Type	Method and Description
String	getBucketName() 获取桶名
int	getProgressInterval() 获取任务进度监听器回调的阈值，默认为50
TaskProgressListener	getProgressListener() 获取批量任务的进度监听器
int	getTaskQueueNum() 获取批量任务的队列长度，默认为20000
int	getTaskThreadNum() 获取批量任务的最大并发数，默认为10
void	setBucketName(String bucketName) 设置桶名
void	setProgressInterval(int taskProgressInterval) 设置任务进度监听器回调的阈值，默认为50
void	setProgressListener(TaskProgressListener listener) 设置批量任务的进度监听器
void	setTaskQueueNum(int taskQueueNum) 设置批量任务中线程池的工作队列长度，默认为20000
void	setTaskThreadNum(int taskThreadNum) 设置批量任务的最大并发数，默认为10

Methods inherited from class com.obs.services.model.GenericRequest

isRequesterPays, setRequesterPays, toString

Methods inherited from class java.lang.Object

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

Field Detail

bucketName

protected String bucketName

listener

protected TaskProgressListener listener

taskThreadNum

protected int taskThreadNum

taskQueueNum

protected int taskQueueNum

taskProgressInterval

protected int taskProgressInterval

Constructor Detail

AbstractBulkRequest

public AbstractBulkRequest()

AbstractBulkRequest

public AbstractBulkRequest(String bucketName)

Method Detail

getBucketName

public String getBucketName()

获取桶名

Returns:

桶名

setBucketName

public void setBucketName(String bucketName)

设置桶名

Parameters:

bucketName - 桶名

getProgressListener

public TaskProgressListener getProgressListener()

获取批量任务的进度监听器

Returns:

进度监听器

setProgressListener

public void setProgressListener(TaskProgressListener listener)

设置批量任务的进度监听器

Parameters:

listener - 进度监听器

getTaskThreadNum

public int getTaskThreadNum()

获取批量任务的最大并发数，默认为10

Returns:

最大线程数

setTaskThreadNum

public void setTaskThreadNum(int taskThreadNum)

设置批量任务的最大并发数，默认为10

Parameters:

taskThreadNum - 最大线程数

getTaskQueueNum

public int getTaskQueueNum()

获取批量任务的队列长度，默认为20000

Returns:

工作队列长度

setTaskQueueNum

public void setTaskQueueNum(int taskQueueNum)

设置批量任务中线程池的工作队列长度，默认为20000

Parameters:

taskQueueNum - 工作队列长度

getProgressInterval

public int getProgressInterval()

获取任务进度监听器回调的阈值，默认为50

Returns:

进度监听器回调的阈值

setProgressInterval

public void setProgressInterval(int taskProgressInterval)

设置任务进度监听器回调的阈值，默认为50

Parameters:

taskProgressInterval - 进度监听器回调的阈值