You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

History

Wei Zhong da3eb2e07e [FLINK-12704][python] Enable the configuration of using blink planner. This closes #9314		6 years ago
..
dev	[FLINK-13488][Python] Remove python 3.3/3.4 support (#9278 )	6 years ago
docs	[hotfix][python][docs] Fix python doc nav bar not showing and layout issue.	6 years ago
lib	…
pyflink	[FLINK-12704][python] Enable the configuration of using blink planner.	6 years ago
src	[FLINK-12767][python] Support user defined connectors/format	6 years ago
MANIFEST.in	[FLINK-12962][python] Allows pyflink to be pip installed.	6 years ago
README.md	[FLINK-12590][docs] Use HTTPS for all Flink links	6 years ago
pom.xml	[FLINK-13308][python] Drop the classifier of the flink-python jar	6 years ago
setup.cfg	[FLINK-12962][python] Allows pyflink to be pip installed.	6 years ago
setup.py	[FLINK-13488][Python] Remove python 3.3/3.4 support (#9278 )	6 years ago
tox.ini	[FLINK-13488][Python] Remove python 3.3/3.4 support (#9278 )	6 years ago

README.md

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/

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

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