com.lucidworks.apollo.pipeline

Class AbstractPipelineManager<M>

java.lang.Object

com.lucidworks.apollo.pipeline.AbstractPipelineManager<M>

Type Parameters:

M -

All Implemented Interfaces:

PipelineManager<M>

Direct Known Subclasses:

IndexPipelineManager

public abstract class AbstractPipelineManager<M>
extends java.lang.Object
implements PipelineManager<M>

Manages the set of currently known Pipelines TODO extract an interface for the history stuff, store history in Solr

Constructor Summary

Constructors

Constructor and Description
AbstractPipelineManager(PipelineDefinitionRegistry pipelineDefinitionRegistry, MetricRegistry metricRegistry, <any> stageConfigRegistry, StageFactory<M> stageFactory, ConfigurationComponent configurationComponent)

Method Summary

Modifier and Type	Method and Description
void	finalizeJob(java.lang.String pipelineId)
ConfigurationComponent	getConfigurationComponent()
java.util.List<PipelineStatus>	getHistoricalJobs(java.lang.String pipelineId)
Pipeline<M>	getOrCreatePipeline(java.lang.String pipelineId, java.util.Map<java.lang.String,java.lang.String> initialProperties) Return the current pipeline instance for the given id, or create one
java.util.Optional<Pipeline<M>>	getPipeline(java.lang.String pipelineId) Return the current pipeline instance for the given id, if it exists

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPipelineManager

public AbstractPipelineManager(PipelineDefinitionRegistry pipelineDefinitionRegistry,
                               MetricRegistry metricRegistry,
                               <any> stageConfigRegistry,
                               StageFactory<M> stageFactory,
                               ConfigurationComponent configurationComponent)

Method Detail

getPipeline

public java.util.Optional<Pipeline<M>> getPipeline(java.lang.String pipelineId)

Description copied from interface: PipelineManager

Return the current pipeline instance for the given id, if it exists

Specified by:

getPipeline in interface PipelineManager<M>

getOrCreatePipeline

public Pipeline<M> getOrCreatePipeline(java.lang.String pipelineId,
                                       java.util.Map<java.lang.String,java.lang.String> initialProperties)

Description copied from interface: PipelineManager

Return the current pipeline instance for the given id, or create one

Specified by:

getOrCreatePipeline in interface PipelineManager<M>

Returns:

getConfigurationComponent

public ConfigurationComponent getConfigurationComponent()

finalizeJob

public void finalizeJob(java.lang.String pipelineId)

Specified by:

finalizeJob in interface PipelineManager<M>

getHistoricalJobs

public java.util.List<PipelineStatus> getHistoricalJobs(java.lang.String pipelineId)