public interface BatchManager
Modifier and Type | Method and Description |
---|---|
void |
addStream(String batchId,
String idx,
InputStream is,
int chunkCount,
int chunkIdx,
String name,
String mime,
long fileSize)
Adds an inputStream as a chunk to a batch.
|
void |
addStream(String batchId,
String idx,
InputStream is,
String name,
String mime)
Adds an inputStream as a blob to a batch.
|
void |
clean(String batchId)
Cleanup the temporary storage associated to the batch
|
Object |
execute(String batchId,
String chainOrOperationId,
CoreSession session,
Map<String,Object> contextParams,
Map<String,Object> operationParams)
Executes the chain or operation on the
Blobs from the given batchId . |
Object |
execute(String batchId,
String fileIdx,
String chainOrOperationId,
CoreSession session,
Map<String,Object> contextParams,
Map<String,Object> operationParams)
Executes the chain or operation on the
Blob from the given batchId and fileIdx . |
Object |
executeAndClean(String batchId,
String chainOrOperationId,
CoreSession session,
Map<String,Object> contextParams,
Map<String,Object> operationParams)
Executes the chain or operation on the
Blobs from the given batchId . |
Blob |
getBlob(String batchId,
String fileId) |
Blob |
getBlob(String batchId,
String fileId,
int timeoutS) |
List<Blob> |
getBlobs(String batchId)
Get Blobs associated to a given batch.
|
List<Blob> |
getBlobs(String batchId,
int timeoutS)
Get Blobs associated to a given batch.
|
List<BatchFileEntry> |
getFileEntries(String batchId) |
BatchFileEntry |
getFileEntry(String batchId,
String fileId) |
TransientStore |
getTransientStore()
Returns the
TransientStore backing the batches. |
boolean |
hasBatch(String batchId)
Returns true if there is a batch for the given
batchId , false otherwise. |
String |
initBatch()
Initialize a batch by with an automatically generated id.
|
String |
initBatch(String batchId,
String contextName)
Initialize a batch with a given batchId and Context Name If batchId is not provided, it will be automatically
generated
|
TransientStore getTransientStore()
TransientStore
backing the batches.void addStream(String batchId, String idx, InputStream is, String name, String mime) throws IOException
Batch
if needed.
Streams are persisted as temporary files.
IOException
void addStream(String batchId, String idx, InputStream is, int chunkCount, int chunkIdx, String name, String mime, long fileSize) throws IOException
Batch
if needed.
Streams are persisted as temporary files.
IOException
boolean hasBatch(String batchId)
batchId
, false otherwise.List<Blob> getBlobs(String batchId)
batchId
- List<Blob> getBlobs(String batchId, int timeoutS)
batchId
- List<BatchFileEntry> getFileEntries(String batchId)
BatchFileEntry getFileEntry(String batchId, String fileId)
void clean(String batchId)
batchId
- String initBatch()
String initBatch(String batchId, String contextName)
batchId
- contextName
- Object execute(String batchId, String chainOrOperationId, CoreSession session, Map<String,Object> contextParams, Map<String,Object> operationParams)
Blobs
from the given batchId
.
This method does not clean the temporary storage associated to the batchId
.
Object execute(String batchId, String fileIdx, String chainOrOperationId, CoreSession session, Map<String,Object> contextParams, Map<String,Object> operationParams)
Blob
from the given batchId
and fileIdx
.
This method does not clean the temporary storage associated to the batchId
.
Object executeAndClean(String batchId, String chainOrOperationId, CoreSession session, Map<String,Object> contextParams, Map<String,Object> operationParams)
Blobs
from the given batchId
.
This method clean the temporary storage associated to the batchId
after the execution.
Copyright © 2015 Nuxeo SA. All rights reserved.