Apache Flink Python API
Project description
Apache Flink
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/
Python Packaging
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/
Python Requirements
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 files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
File details
Details for the file apache-flink-1.9.2.tar.gz.
File metadata
- Download URL: apache-flink-1.9.2.tar.gz
- Upload date:
- Size: 251.1 MB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/3.1.1 pkginfo/1.5.0.1 requests/2.22.0 setuptools/42.0.2 requests-toolbelt/0.9.1 tqdm/4.41.1 CPython/3.7.6
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 76c18408afbabe1c1903a8c84f6f67c032f7ce2df4353d9c77f526ff5face975 |
|
| MD5 | 2f8f1c1091227735d995cef8fad94c7c |
|
| BLAKE2b-256 | d7d4ee61e98449c7ccd8a2235b7f31aa3f1e3ba15e7c1c3d7d66f12391c250a5 |
