Package nz.org.riskscape.engine.output
Class FileSystemPipelineOutputStore
java.lang.Object
nz.org.riskscape.engine.output.FileSystemPipelineOutputStore
- All Implemented Interfaces:
nz.org.riskscape.engine.Identified
,nz.org.riskscape.engine.output.PipelineOutputStore
public class FileSystemPipelineOutputStore
extends Object
implements nz.org.riskscape.engine.output.PipelineOutputStore
A PipelineOutputStore
that writes results to files on the file system.
If the user specifies an output base URI then that is used as the directory in which results are saved. If not provided then the output base directory is PROJECTOUTPUTDIRECTORY/PIPELINE_ID/TIMESTAMP.
-
Field Summary
Fields inherited from interface nz.org.riskscape.engine.output.PipelineOutputStore
PRIORITY_DEFAULT, PRIORITY_HIGH, PRIORITY_NA
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
FileSystemPipelineOutputStore
(Supplier<LocalDateTime> currentTime) Test constructor allowing control of the current time. -
Method Summary
Modifier and TypeMethodDescriptionnz.org.riskscape.problem.ResultOrProblems<nz.org.riskscape.engine.output.PipelineOutputContainer>
create
(URI outputLocation, nz.org.riskscape.engine.pipeline.RealizedPipeline pipeline, nz.org.riskscape.engine.output.PipelineOutputOptions options) getId()
int
isApplicable
(URI outputLocation) void
onCompletion
(Consumer<nz.org.riskscape.engine.output.FileSystemPipelineOutputStore.FileSystemPipelineContainer> action) Register an action to perform once a FileSystemPipelineContainer has completed saving all the output data.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface nz.org.riskscape.engine.Identified
getIdentifiedClass
Methods inherited from interface nz.org.riskscape.engine.output.PipelineOutputStore
newOutputOptions
-
Constructor Details
-
FileSystemPipelineOutputStore
public FileSystemPipelineOutputStore() -
FileSystemPipelineOutputStore
Test constructor allowing control of the current time.
-
-
Method Details
-
isApplicable
- Specified by:
isApplicable
in interfacenz.org.riskscape.engine.output.PipelineOutputStore
-
create
public nz.org.riskscape.problem.ResultOrProblems<nz.org.riskscape.engine.output.PipelineOutputContainer> create(URI outputLocation, nz.org.riskscape.engine.pipeline.RealizedPipeline pipeline, nz.org.riskscape.engine.output.PipelineOutputOptions options) - Specified by:
create
in interfacenz.org.riskscape.engine.output.PipelineOutputStore
-
onCompletion
public void onCompletion(Consumer<nz.org.riskscape.engine.output.FileSystemPipelineOutputStore.FileSystemPipelineContainer> action) Register an action to perform once a FileSystemPipelineContainer has completed saving all the output data.
-
getId
- Specified by:
getId
in interfacenz.org.riskscape.engine.Identified
-