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

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
nz.org.riskscape.engine.output.PipelineOutputContainer	createContainer(CliPipelineRunnerOptions cliOptions, nz.org.riskscape.engine.pipeline.RealizedPipeline pipeline)
static String	createDirFriendlyTimestamp(LocalDateTime dateTime)
Optional<nz.org.riskscape.engine.util.ProgressNotifier>	createProgressNotifier(CliPipelineRunnerOptions options, com.codahale.metrics.MetricRegistry metrics, nz.org.riskscape.engine.Project useProject)
void	run(nz.org.riskscape.engine.pipeline.RealizedPipeline realized, nz.org.riskscape.engine.pipeline.PipelineExecutor executor, nz.org.riskscape.engine.Project useProject, CliPipelineRunnerOptions 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,
 CliPipelineRunnerOptions options)

createContainer

public nz.org.riskscape.engine.output.PipelineOutputContainer createContainer(CliPipelineRunnerOptions cliOptions,
 nz.org.riskscape.engine.pipeline.RealizedPipeline pipeline)

createProgressNotifier

public Optional<nz.org.riskscape.engine.util.ProgressNotifier> createProgressNotifier(CliPipelineRunnerOptions options,
 com.codahale.metrics.MetricRegistry metrics,
 nz.org.riskscape.engine.Project useProject)