Class BatchManager

java.lang.Object

org.ojalgo.data.batch.BatchManager

public final class BatchManager
extends Object

When you're going to instantiate multiple BatchNode:s and you want them to share some properties, this is a convenient alternative. Just create a BatchManager, configure it, and use it to create the BatchNode.Builder:s using newNodeBuilder(String, DataInterpreter).

Field Summary

Fields

Modifier and Type	Field	Description
private final File	myBatchRootDirectory
private ExecutorService	myExecutor
private Integer	myFragmentation
private boolean	myManaged
private IntSupplier	myParallelism
private Integer	myQueueCapacity

Constructor Summary

Constructors

Constructor	Description
BatchManager(File batchRootDirectory)

Method Summary

Modifier and Type	Method	Description
void	dispose()	Dispose of all files associated with nodes instantiated from this manager.
BatchManager	executor(ExecutorService executor)
BatchManager	fragmentation(int fragmentation)
BatchManager	managed(boolean managed)
<T> BatchNode.Builder<T>	newNodeBuilder(String nodeName, DataInterpreter<T> dataInterpreter)
BatchManager	parallelism(int parallelism)
BatchManager	parallelism(IntSupplier parallelism)
BatchManager	queue(int capacity)

Methods inherited from class Object

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

Field Details

myBatchRootDirectory

private final File myBatchRootDirectory

myExecutor

private ExecutorService myExecutor

myFragmentation

private Integer myFragmentation

myManaged

private boolean myManaged

myParallelism

private IntSupplier myParallelism

myQueueCapacity

private Integer myQueueCapacity

Constructor Details

BatchManager

public BatchManager(File batchRootDirectory)

Method Details

dispose

public void dispose()

Dispose of all files associated with nodes instantiated from this manager. It's recommended that you call BatchNode.dispose() on the individual nodes as you're done with them. This is just a convenient alternative to dispose of multiple (all) nodes simultaneously.

See Also:

• BatchNode.dispose()

executor

public BatchManager executor(ExecutorService executor)

See Also:

• BatchNode.Builder.executor(ExecutorService)

fragmentation

public BatchManager fragmentation(int fragmentation)

See Also:

• BatchNode.Builder.fragmentation(int)

managed

public BatchManager managed(boolean managed)

newNodeBuilder

public <T> BatchNode.Builder<T> newNodeBuilder(String nodeName,
 DataInterpreter<T> dataInterpreter)

parallelism

public BatchManager parallelism(int parallelism)

See Also:

• BatchNode.Builder.parallelism(int)

parallelism

public BatchManager parallelism(IntSupplier parallelism)

See Also:

• BatchNode.Builder.parallelism(IntSupplier)

queue

public BatchManager queue(int capacity)

See Also:

• BatchNode.Builder.queue(int)