public interface PipelineManager<M>
Modifier and Type | Method and Description |
---|---|
void |
finalizeJob(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
|
<any> |
getPipeline(java.lang.String pipelineId)
Return the current pipeline instance for the given id, if it exists
|
<any> getPipeline(java.lang.String pipelineId)
pipelineId
- Pipeline<M> getOrCreatePipeline(java.lang.String pipelineId, java.util.Map<java.lang.String,java.lang.String> initialProperties)
pipelineId
- initialProperties
- void finalizeJob(java.lang.String pipelineId)