Getting Started

Flink Tasks for Python can be installed from PyPi using pip

pip install statefun-tasks

See the GitHub repo for some examples.

The pipeline function can be downloaded here or alternatively is available as a ready made container image comprising Flink Statefun and the pipeline function.

See the demo application as a guide for spinning up an environment on Kubernetes.