Flowman Introduction

https://img.shields.io/badge/License-Apache%202.0-blue.svgLicense https://travis-ci.org/dimajix/flowman.svg?branch=developBuild Status https://readthedocs.org/projects/flowman/badge/?version=latestDocumentation

What is Flowman

Flowman is a Spark based ETL program that simplifies the act of writing data transformations. The main idea is that users write so called specifications in purely declarative YAML files instead of writing Spark jobs in Scala or Python. The main advantage of this approach is that many technical details of a correct and robust implementation are encapsulated and the user can concentrate on the data transformations themselves.

In addition to writing and executing data transformations, Flowman can also be used for managing physical data models, i.e. Hive tables. Flowman can create such tables from a specification with the correct schema. This helps to keep all aspects (like transformations and schema information) in a single place managed by a single program.

Noteable Features

  • Declarative syntax in YAML files
  • Data model management (Create and Destroy Hive tables or file based storage)
  • Flexible expression language
  • Jobs for managing build targets (like copying files or uploading data via sftp)
  • Powerful yet simple command line tool
  • Extendable via Plugins

Where to go from here


A small quickstart guide will lead you through a simple example.


CLI Documentation

Flowman provides a command line utility (CLI) for running flows. Details are described in the following sections:

Specification Documentation

So called specifications describe the logical data flow, data sources and more. A full specification contains multiple entities like mappings, data models and jobs to be executed. More detail on all these items is described in the following sections:

  • Specification Overview: An introduction for writing new flows
  • Mappings: Documentation of available data transformations
  • Relations: Documentation of available data sources and sinks
  • Targets: Documentation of available build targets
  • Schema: Documentation of available schema descriptions
  • Jobs: Documentation of creating jobs and building targets


  • Testing How to implement tests in Flowman
  • Kerberos How to use Flowman in Kerberized environments