ome.smuggler.core.service.imports.impl

Class BatchManager

java.lang.Object

ome.smuggler.core.service.imports.impl.BatchManager

public class BatchManager
extends java.lang.Object

Manages the life-cycle of ImportBatches.

Constructor Summary

Constructors

Constructor and Description
BatchManager(ImportEnv env) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
protected ImportBatch	createBatchFor(java.util.stream.Stream<ImportInput> requests) Creates a new batch containing the specified import requests.
protected void	deleteBatch(ImportBatchId batchId) Removes the specified batch from permanent storage.
protected ImportBatchStatus	getBatchStatusOf(ProcessedImport task) Retrieves the current state of the batch containing the specified task.
protected void	updateBatchOf(ProcessedImport task) Updates the batch containing the specified import task to mark the import as completed within the batch.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchManager

public BatchManager(ImportEnv env)

Creates a new instance.

Parameters:

env - the import environment.

Throws:

java.lang.NullPointerException - if the argument is null.

Method Detail

createBatchFor

protected ImportBatch createBatchFor(java.util.stream.Stream<ImportInput> requests)

Creates a new batch containing the specified import requests.

Parameters:

requests - the import requests to queue.

Returns:

the new batch.

Throws:

java.lang.NullPointerException - if the stream or any of its elements is null.

java.lang.IllegalArgumentException - if the stream is empty.

getBatchStatusOf

protected ImportBatchStatus getBatchStatusOf(ProcessedImport task)

Retrieves the current state of the batch containing the specified task.

Parameters:

task - the import task.

Returns:

the corresponding batch state.

Throws:

java.lang.NullPointerException - if the argument is null.

deleteBatch

protected void deleteBatch(ImportBatchId batchId)

Removes the specified batch from permanent storage.

Parameters:

batchId - identifies the batch.

Throws:

java.lang.NullPointerException - if the argument is null.

updateBatchOf

protected void updateBatchOf(ProcessedImport task)

Updates the batch containing the specified import task to mark the import as completed within the batch.

Parameters:

task - the import task.

Throws:

java.lang.NullPointerException - if the argument is null.