Wraps processing in a transaction and commits it in the finished phase This allows executions to be tagged with an execution ID, which is intended to unqiuely identify an import or export of this pipeline. This can be used to prevent multiple processings of the same data. For example, you might have a file containing points being loaded once each day. You might use an execution ID template which evaluates to (for example) "points-31012015". Then if another execution generated the same ID you would conclude this is a double-import and throw an error.
Implements: PipelineStep
Properties
| Property | Returns | Description |
|---|---|---|
| description | String | Short, human-readable description of this step shown to administrators managing a pipeline. |
| execIdTemplate | String | The MVEL template used to build this run's execution ID. Evaluated against the pipeline's data when the step runs, to produce a value that uniquely identifies this particular import or export. |
| formPath | String | Path to the velocity template that renders this step's management UI form. |
| next | PipelineStep | The single step that follows this one in the pipeline, or null if none has been configured. |
| nextStep | PipelineStep | The single step that follows this one in the pipeline, or null if none has been configured. Equivalent to getNext. |
| preventDuplicates | boolean | Whether this step should refuse to run when a previous execution already recorded the same execution ID, to guard against processing the same data twice. |
Methods
getFormPath()
Returns: String
Path to the velocity template that renders this step's management UI form.
getDescription()
Returns: String
Short, human-readable description of this step shown to administrators managing a pipeline.
getNext()
Returns: PipelineStep
The single step that follows this one in the pipeline, or null if none has been configured.
getNextStep()
Returns: PipelineStep
The single step that follows this one in the pipeline, or null if none has been configured. Equivalent to getNext.
getExecIdTemplate()
Returns: String
The MVEL template used to build this run's execution ID. Evaluated against the pipeline's data when the step runs, to produce a value that uniquely identifies this particular import or export.
isPreventDuplicates()
Returns: boolean
Whether this step should refuse to run when a previous execution already recorded the same execution ID, to guard against processing the same data twice.