metalus

This project aims to make writing Spark applications easier by abstracting the effort to assemble the driver into reusable steps and pipelines.

View project on GitHub
Documentation Home Core Home

ExceptionSteps

This step object provides a way to throw exceptions from within a pipeline.

Throw Pipeline Step Exception

This step will throw the PipelineException which is used to stop execution of the current pipeline. Full parameter descriptions are listed below:

  • message - The message to log for this exception.

    Throw Skip Execution Exception

    This step will throw the SkipExecutionPipelineStepException which is used in execution evaluation pipelines. Full parameter descriptions are listed below:

  • message - The message to log for this exception.