Package nz.org.riskscape.engine.cli.pipeline

Class CliPipelineRunner

java.lang.Object

nz.org.riskscape.engine.cli.pipeline.CliPipelineRunner

public class CliPipelineRunner
extends Object

Has code for running the execution of a realized pipeline and sending the output etc to the right place. Factored out here for reuse from other commands

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	CliPipelineRunner.Options

Field Summary

Fields

Modifier and Type	Field	Description
static final String	MONITOR_PROGRESS_DEFAULT

Constructor Summary

Constructors

Constructor	Description
CliPipelineRunner(nz.org.riskscape.cli.Terminal terminal)
CliPipelineRunner(nz.org.riskscape.cli.Terminal terminal, Supplier<LocalDateTime> currentTime)

Method Summary

Modifier and Type	Method	Description
static String	createDirFriendlyTimestamp(LocalDateTime dateTime)
CliPipelineRunner.Options	newDefaultOptions(String outputName)
void	run(nz.org.riskscape.engine.pipeline.RealizedPipeline realized, nz.org.riskscape.engine.pipeline.PipelineExecutor executor, nz.org.riskscape.engine.Project useProject, CliPipelineRunner.Options options)

Methods inherited from class java.lang.Object

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

Field Details

MONITOR_PROGRESS_DEFAULT

public static final String MONITOR_PROGRESS_DEFAULT

See Also:

• Constant Field Values

Constructor Details

CliPipelineRunner

public CliPipelineRunner(nz.org.riskscape.cli.Terminal terminal)

CliPipelineRunner

public CliPipelineRunner(nz.org.riskscape.cli.Terminal terminal,
 Supplier<LocalDateTime> currentTime)

Method Details

createDirFriendlyTimestamp

public static String createDirFriendlyTimestamp(LocalDateTime dateTime)

Returns:

a file system path friendly string that represents the given datetime.

run

public void run(nz.org.riskscape.engine.pipeline.RealizedPipeline realized,
 nz.org.riskscape.engine.pipeline.PipelineExecutor executor,
 nz.org.riskscape.engine.Project useProject,
 CliPipelineRunner.Options options)

newDefaultOptions

public CliPipelineRunner.Options newDefaultOptions(String outputName)

Parameters:

outputName -

Returns: