Package com.lucidworks.apollo.pipeline

Class DefaultBasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M>

java.lang.Object

com.lucidworks.apollo.pipeline.DefaultBasePipelineComponent<T,M>

Type Parameters:

T -

M -

All Implemented Interfaces:

BasePipelineComponent<T,M>

public abstract class DefaultBasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M>
extends Object
implements BasePipelineComponent<T,M>

Base implementation of the BasePipelineComponent.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DefaultBasePipelineComponent(com.lucidworks.apollo.store.ItemReadWriteStore<T> pipelineDefinitionRegistry, PipelineManager<M> pipelineManager, ConfigurationComponent configurationComponent)

Method Summary

Modifier and Type	Method	Description
com.lucidworks.apollo.store.ItemReadStore.ItemAndVersion<T>	getPipeline(String pipelineId)
com.lucidworks.apollo.store.ItemReadWriteStore<T>	getPipelineDefinitionRegistry()
PipelineManager<M>	getPipelineManager()
protected com.lucidworks.apollo.store.ItemReadStore.ItemAndVersion<T>	getPipelineOrFail(String pipelineId)
boolean	managedModeEnabled()
void	refreshPipeline(String pipelineId)
void	stopAndFinalizePipelineJob(String pipelineId)

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultBasePipelineComponent

protected DefaultBasePipelineComponent(com.lucidworks.apollo.store.ItemReadWriteStore<T> pipelineDefinitionRegistry,
 PipelineManager<M> pipelineManager,
 ConfigurationComponent configurationComponent)

Method Details

getPipeline

public com.lucidworks.apollo.store.ItemReadStore.ItemAndVersion<T> getPipeline(String pipelineId)

Specified by:

getPipeline in interface BasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M>

getPipelineDefinitionRegistry

public com.lucidworks.apollo.store.ItemReadWriteStore<T> getPipelineDefinitionRegistry()

Specified by:

getPipelineDefinitionRegistry in interface BasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M>

getPipelineOrFail

protected com.lucidworks.apollo.store.ItemReadStore.ItemAndVersion<T> getPipelineOrFail(String pipelineId)

refreshPipeline

public void refreshPipeline(String pipelineId)

Specified by:

refreshPipeline in interface BasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M>

stopAndFinalizePipelineJob

public void stopAndFinalizePipelineJob(String pipelineId)

Specified by:

stopAndFinalizePipelineJob in interface BasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M>

getPipelineManager

public PipelineManager<M> getPipelineManager()

Specified by:

getPipelineManager in interface BasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M>

managedModeEnabled

public boolean managedModeEnabled()

Specified by:

managedModeEnabled in interface BasePipelineComponent<T extends com.lucidworks.apollo.pipeline.PipelineDefinition<T>,M>