Skip to main content

Apache Flink Python API

Project description

# Apache Flink Python API

Apache Flink is an open source stream processing framework with the powerful stream- and batch-processing capabilities.

Learn more about Flink at [https://flink.apache.org/](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-master/dev/table/tableApi.html](https://ci.apache.org/projects/flink/flink-docs-master/dev/table/tableApi.html)

## Installation

Currently, we can install PyFlink from Flink source code. Enter the directory where this README.md file is located and install PyFlink on your device by executing

` python setup.py install `

## Running test cases

Currently, we use conda and tox to verify the compatibility of the Flink Python API for multiple versions of Python and will integrate some useful plugins with tox, such as flake8. We can enter the directory where this README.md file is located and run test cases by executing

` ./dev/lint-python.sh `

## Python Requirements

PyFlink depends on Py4J (currently version 0.10.8.1).

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 zw-flink, version 1.11
Filename, size & hash File type Python version Upload date
zw-flink-1.11rc3.tar.gz (281.8 kB) View hashes Source None

Supported by

Elastic Elastic Search Pingdom Pingdom Monitoring Google Google BigQuery Sentry Sentry Error logging AWS AWS Cloud computing DataDog DataDog Monitoring Fastly Fastly CDN SignalFx SignalFx Supporter DigiCert DigiCert EV certificate StatusPage StatusPage Status page