public class GetStreamerStrategy extends BlobStrategy
BlobStrategy.ChunkEventHandler| Constructor and Description |
|---|
GetStreamerStrategy(Ds3Client client,
MasterObjectList masterObjectList,
int retryAfter,
int retryDelay,
BlobStrategy.ChunkEventHandler chunkEventHandler) |
| Modifier and Type | Method and Description |
|---|---|
void |
blobCompleted(BulkObject bulkObject) |
java.lang.Iterable<JobPart> |
getWork() |
computeDelay, getChunkEventHandler, getClient, getMasterObjectList, getRetryAfter, getRetryDelaypublic GetStreamerStrategy(Ds3Client client, MasterObjectList masterObjectList, int retryAfter, int retryDelay, BlobStrategy.ChunkEventHandler chunkEventHandler)
public java.lang.Iterable<JobPart> getWork() throws java.io.IOException, java.lang.InterruptedException
getWork in class BlobStrategyjava.io.IOExceptionjava.lang.InterruptedExceptionpublic void blobCompleted(BulkObject bulkObject)
blobCompleted in class BlobStrategy