Nussknacker consists of three parts:

  • engine
  • ui
  • integrations

Engine is a library which transforms json representation of graph with Nussknacker process into Flink job.

UI is a standalone application which allows user to design process diagrams and to deploy them into Flink cluster

Integrations is your application specific classes like your model, http services, or custom stateful components.


Engine consists of various modules that enable creation of processes building blocks and interpretation of process diagrams

The most important modules are:

  • api
  • interpreter
  • process


The UI application is a simple Scala application written using Akka Http and Slick. Processes, their history, comments and other metadata are persisted in relational database (by default it's simple embedded H2). UI communicates with Apache Flink cluster using embedded Flink client.


Integrations module implements ProcessConfigCreator interface which is an entry point of Nussknacker.

results matching ""

    No results matching ""