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

PropertyReturnsDescription
descriptionStringShort, human-readable description of this step shown to administrators managing a pipeline.
execIdTemplateStringThe 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.
formPathStringPath to the velocity template that renders this step's management UI form.
nextPipelineStepThe single step that follows this one in the pipeline, or null if none has been configured.
nextStepPipelineStepThe single step that follows this one in the pipeline, or null if none has been configured. Equivalent to getNext.
preventDuplicatesbooleanWhether 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.

To get full access to the Kademi Hub existing customers can login here, or new customers can register here.