T
- input-object typeS
- shared-object typepublic class SequentialProcessor<T extends InputFromManager,S> extends JobProcessor<T,S>
This is the simplest form of a JobProcessor
.
Constructor and Description |
---|
SequentialProcessor() |
Modifier and Type | Method and Description |
---|---|
protected TaskStatistics |
execute(Outputter rootOutputter,
List<T> inputs,
ParametersExperiment parametersExperiment)
Executes the task on all
inputs . |
executeLogStatistics, getTask, hasVeryQuickPerInputExecution, isInputCompatibleWith, isSuppressExceptions, replaceTask, setSuppressExceptions, setTask
checkMisconfigured, describeBean, describeChildren, duplicateBean, fields, findFieldsOfClass, getBeanName, getLocalPath, localise, toString
protected TaskStatistics execute(Outputter rootOutputter, List<T> inputs, ParametersExperiment parametersExperiment) throws ExperimentExecutionException
JobProcessor
inputs
.
It is expected that elements are removed from inputs
as they are consumed so as to
allow garbage-collection of these items before all jobs are processed (as the list might be
quite large).
execute
in class JobProcessor<T extends InputFromManager,S>
rootOutputter
- an outputter, bound to the base (root) output directory into which
outputted files are written.inputs
- the inputs to apply task
on.parametersExperiment
- parameters that exist pertaining to the experiment that is
underway.ExperimentExecutionException
- if anything goes wrong executing the experiment (but not
necessarily if a processing a particular input fails when suppressExceptions ==
true
.Copyright © 2010–2023 Owen Feehan, ETH Zurich, University of Zurich, Hoffmann-La Roche. All rights reserved.