com.lucidworks.apollo.pipeline

Class DefaultBasePipelineComponent<T extends 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 PipelineDefinition<T>,M>
extends java.lang.Object
implements BasePipelineComponent<T,M>

Base implementation of the BasePipelineComponent.

Method Summary

Modifier and Type	Method and Description
void	deletePipeline(java.lang.String pipelineId, int version)
ClientComponent	getClientComponent()
java.lang.Class<? extends com.lucidworks.apollo.client.resources.AbstractPipelineClientResource>	getClientInterface()
com.lucidworks.apollo.component.crud.UpdateBuilder<T>	getCreateBuilder()
com.lucidworks.apollo.component.crud.DeleteBuilder	getDeleteBuilder()
com.lucidworks.apollo.component.crud.ListBuilder<T>	getListBuilder()
<any>	getPipeline(java.lang.String pipelineId)
<any>	getPipelineDefinitionRegistry()
PipelineManager<M>	getPipelineManager()
com.lucidworks.apollo.component.crud.ReadBuilder<T>	getReadBuilder()
com.lucidworks.apollo.component.crud.UpdateBuilder<T>	getUpdateBuilder(java.lang.String idFromUrl)
java.util.Collection<T>	listPipelines() list the pipelines
void	refreshPipeline(java.lang.String pipelineId)
void	setClientInterfaceClazz(java.lang.Class<? extends com.lucidworks.apollo.client.resources.AbstractPipelineClientResource> clientInterfaceClazz)
void	stopAndFinalizePipelineJob(java.lang.String pipelineId)
void	validateStages(T pipeline)

Methods inherited from class java.lang.Object

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

Method Detail

setClientInterfaceClazz

public void setClientInterfaceClazz(java.lang.Class<? extends com.lucidworks.apollo.client.resources.AbstractPipelineClientResource> clientInterfaceClazz)

Specified by:

setClientInterfaceClazz in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

listPipelines

public java.util.Collection<T> listPipelines()
                                      throws com.lucidworks.apollo.common.error.ComponentError

Description copied from interface: BasePipelineComponent

list the pipelines

Specified by:

listPipelines in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

Returns:

Throws:

com.lucidworks.apollo.common.error.ComponentError

getPipeline

public <any> getPipeline(java.lang.String pipelineId)
                  throws com.lucidworks.apollo.common.error.ComponentError

Specified by:

getPipeline in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

Throws:

com.lucidworks.apollo.common.error.ComponentError

getPipelineDefinitionRegistry

public <any> getPipelineDefinitionRegistry()

Specified by:

getPipelineDefinitionRegistry in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

getListBuilder

public com.lucidworks.apollo.component.crud.ListBuilder<T> getListBuilder()

Specified by:

getListBuilder in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

getReadBuilder

public com.lucidworks.apollo.component.crud.ReadBuilder<T> getReadBuilder()

Specified by:

getReadBuilder in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

getCreateBuilder

public com.lucidworks.apollo.component.crud.UpdateBuilder<T> getCreateBuilder()

Specified by:

getCreateBuilder in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

getUpdateBuilder

public com.lucidworks.apollo.component.crud.UpdateBuilder<T> getUpdateBuilder(java.lang.String idFromUrl)

Specified by:

getUpdateBuilder in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

getDeleteBuilder

public com.lucidworks.apollo.component.crud.DeleteBuilder getDeleteBuilder()

Specified by:

getDeleteBuilder in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

deletePipeline

public void deletePipeline(java.lang.String pipelineId,
                           int version)
                    throws com.lucidworks.apollo.common.error.ComponentError

Specified by:

deletePipeline in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

Throws:

com.lucidworks.apollo.common.error.ComponentError

validateStages

public void validateStages(T pipeline)
                    throws com.lucidworks.apollo.common.error.ComponentError

Specified by:

validateStages in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

Throws:

com.lucidworks.apollo.common.error.ComponentError

getClientComponent

public ClientComponent getClientComponent()

Specified by:

getClientComponent in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

refreshPipeline

public void refreshPipeline(java.lang.String pipelineId)
                     throws com.lucidworks.apollo.common.error.ComponentError

Specified by:

refreshPipeline in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

Throws:

com.lucidworks.apollo.common.error.ComponentError

stopAndFinalizePipelineJob

public void stopAndFinalizePipelineJob(java.lang.String pipelineId)

Specified by:

stopAndFinalizePipelineJob in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

getClientInterface

public java.lang.Class<? extends com.lucidworks.apollo.client.resources.AbstractPipelineClientResource> getClientInterface()

Specified by:

getClientInterface in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>

getPipelineManager

public PipelineManager<M> getPipelineManager()

Specified by:

getPipelineManager in interface BasePipelineComponent<T extends PipelineDefinition<T>,M>