In this section you will learn how to create Nussknacker processes using defined model. In the examples we'll use sample model that comes with Nussknacker distribution. You can find latest sources here.
Global process properties
- parallelism (see Flink docs)
- checkpoint interval (see Flink docs)
- should state be kept in memory, or should RocksDB be used (see Flink docs)
- properties for configuring ExceptionHandler of model
In the beginning there is only one variable -
input, contains single record for processing.
Currently expressions in Nussknacker can be written using Spring Expression Language. You can find extensive documentation here. Autocomplete function (Ctrl-Space) is available in expression input boxes.
Node works with a data stream. It can produce, fetch, send, collect data or organize data flow.
Each node has at least two parameters:
Description. Name has to be unique in process. It identifies node usage. Description is as everyone can see.
Depending on its type, node can have input and output. Input has to have exactly one assigned flow from another node. Output can have multiple flows, or none, or can have at least one obligatory.
Subprocesses let you abstract common used parts of process. See subprocesses for more detailed description of how they work.
More complex operations like joins or aggregations are handled by custom nodes, their usage and semantics can depend on execution engine. Please refer to Flink custom transformers for examples.