T
- fulfill the role of pipeline definitionM
- fulfills the role of pipeline managerpublic interface BasePipelineComponent<T extends PipelineDefinition<T>,M>
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,
UriInfo uriInfo) |
java.util.Collection<T> |
listPipelines()
list the pipelines
|
boolean |
managedModeEnabled() |
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) |
void setClientInterfaceClazz(java.lang.Class<? extends com.lucidworks.apollo.client.resources.AbstractPipelineClientResource> clientInterfaceClazz)
java.util.Collection<T> listPipelines() throws com.lucidworks.apollo.common.error.ComponentError
com.lucidworks.apollo.common.error.ComponentError
<any> getPipeline(java.lang.String pipelineId) throws com.lucidworks.apollo.common.error.ComponentError
com.lucidworks.apollo.common.error.ComponentError
<any> getPipelineDefinitionRegistry()
com.lucidworks.apollo.component.crud.ListBuilder<T> getListBuilder()
com.lucidworks.apollo.component.crud.ReadBuilder<T> getReadBuilder()
com.lucidworks.apollo.component.crud.UpdateBuilder<T> getCreateBuilder()
com.lucidworks.apollo.component.crud.UpdateBuilder<T> getUpdateBuilder(java.lang.String idFromUrl, UriInfo uriInfo)
com.lucidworks.apollo.component.crud.DeleteBuilder getDeleteBuilder()
void deletePipeline(java.lang.String pipelineId, int version) throws com.lucidworks.apollo.common.error.ComponentError
com.lucidworks.apollo.common.error.ComponentError
void validateStages(T pipeline) throws com.lucidworks.apollo.common.error.ComponentError
com.lucidworks.apollo.common.error.ComponentError
ClientComponent getClientComponent()
void refreshPipeline(java.lang.String pipelineId) throws com.lucidworks.apollo.common.error.ComponentError
com.lucidworks.apollo.common.error.ComponentError
void stopAndFinalizePipelineJob(java.lang.String pipelineId)
java.lang.Class<? extends com.lucidworks.apollo.client.resources.AbstractPipelineClientResource> getClientInterface()
PipelineManager<M> getPipelineManager()
boolean managedModeEnabled()