Skip to main content

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).

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Files for apache-flink, version 1.9.2
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

Supported by

Pingdom Pingdom Monitoring Google Google Object Storage and Download Analytics Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN DigiCert DigiCert EV certificate StatusPage StatusPage Status page