Skip to content


Pipelines are data science programs designed to solve a specific task. They act as the entry point to start execution. Pipelines are not meant to be reusable, instead extract reusable code into a segment.


Minimal Example

Let's look at a minimal example of a pipeline:

pipeline predictSpeed {}

This declaration of a pipeline has the following syntactic elements:

  • The keyword pipeline.
  • The name of the pipeline, here predictSpeed, which can be any combination of upper- and lowercase letters, underscores, and numbers, as long as it does not start with a number. However, we suggest to use lowerCamelCase for the names of pipelines.
  • The body of the pipeline, which contains the statements that should be run when the pipeline is executed. The body is delimited by curly braces. In this example, the body is empty, so running this pipeline does nothing.


In order to describe what should be done when the pipeline is executed, we need to add statements to its body, as shown in this example:

pipeline predictSpeed {
    val adac = loadDataset("ADAC");
    val adacSample = adac.sample(1000);

    // …

More information about statements can be found in the linked document. Note particularly, that all statements must end with a semicolon.