Apache Flink Python API
Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams. Flink has been designed to run in all common cluster environments, perform computations at in-memory speed and at any scale.
Learn more about Flink at https://flink.apache.org/
This packaging allows you to write Flink programs in Python, but it is currently a very initial version and will change in future versions.
In this initial version only Table API is supported, you can find the documentation at https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/tableApi.html
The tutorial can be found at https://ci.apache.org/projects/flink/flink-docs-release-1.9/tutorials/python_table_api.html
The auto-generated Python docs can be found at https://ci.apache.org/projects/flink/flink-docs-release-1.9/api/python/
Apache Flink Python API depends on Py4J (currently version 0.10.8.1) and python-dateutil(currently version 2.8.0).
Release history Release notifications | RSS feed
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
|Filename, size||File type||Python version||Upload date||Hashes|
|Filename, size apache-flink-1.9.2.tar.gz (251.1 MB)||File type Source||Python version None||Upload date||Hashes View|