Package com.lucidworks.apollo.pipeline

Class AbstractPipelineManager<M>

java.lang.Object

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

Type Parameters:

M -

All Implemented Interfaces:

PipelineManager<M>

public abstract class AbstractPipelineManager<M>
extends 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	Description
AbstractPipelineManager(PipelineDefinitionRegistry pipelineDefinitionRegistry, com.codahale.metrics.MetricRegistry metricRegistry, StageFactory<M> stageFactory, ConfigurationComponent configurationComponent)

Method Summary

Modifier and Type	Method	Description
void	finalizeJob(String pipelineId)
ConfigurationComponent	getConfigurationComponent()
List<PipelineStatus>	getHistoricalJobs(String pipelineId)
Pipeline<M>	getOrCreatePipeline(String pipelineId)	Return the current pipeline instance for the given id, or create one
Pipeline<M>	getOrCreatePipeline(String pipelineId, Map<String,String> initialProperties)	Return the current pipeline instance for the given id, or create one
protected Pipeline<M>	getOrCreatePipelineImpl(String pipelineId)
Optional<Pipeline<M>>	getPipeline(String pipelineId)	Return the current pipeline instance for the given id, if it exists
protected abstract Pipeline<M>	newPipeline(String instanceId, String pipelineId, List<com.lucidworks.apollo.pipeline.StageConfig> stageConfigs, StageFactory<M> stageFactory, com.codahale.metrics.MetricRegistry metricRegistry, Map<String,String> initialProperties)	Delegate the actual construction of a Pipeline instance to a subclass, so we can get subtypes of Pipeline

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractPipelineManager

public AbstractPipelineManager(PipelineDefinitionRegistry pipelineDefinitionRegistry,
 com.codahale.metrics.MetricRegistry metricRegistry,
 StageFactory<M> stageFactory,
 ConfigurationComponent configurationComponent)

Method Details

getPipeline

public Optional<Pipeline<M>> getPipeline(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(String pipelineId)

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:

getOrCreatePipeline

public Pipeline<M> getOrCreatePipeline(String pipelineId,
 Map<String,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>

initialProperties - - not used

Returns:

getConfigurationComponent

public ConfigurationComponent getConfigurationComponent()

newPipeline

protected abstract Pipeline<M> newPipeline(String instanceId,
 String pipelineId,
 List<com.lucidworks.apollo.pipeline.StageConfig> stageConfigs,
 StageFactory<M> stageFactory,
 com.codahale.metrics.MetricRegistry metricRegistry,
 Map<String,String> initialProperties)

Delegate the actual construction of a Pipeline instance to a subclass, so we can get subtypes of Pipeline

getOrCreatePipelineImpl

protected Pipeline<M> getOrCreatePipelineImpl(String pipelineId)

finalizeJob

public void finalizeJob(String pipelineId)

Specified by:

finalizeJob in interface PipelineManager<M>

getHistoricalJobs

public List<PipelineStatus> getHistoricalJobs(String pipelineId)