{"library":"apache-flink","type":"library","category":null,"description":"PyFlink is the Python API for Apache Flink, a powerful open-source stream-processing framework. It enables users to write Flink jobs using Python's DataStream and Table APIs, leveraging Flink's robust capabilities for stateful computations, fault tolerance, and high throughput. Version 2.2.0 is compatible with Flink 1.18+ and requires Python 3.9+. New releases generally align with major Flink core updates and maintain a consistent release cadence.","language":"python","status":"active","version":"2.2.0","tags":["apache flink","pyflink","data streaming","stream processing","big data","etl","distributed systems"],"last_verified":"Tue May 26","install":[{"cmd":"pip install apache-flink","imports":["from pyflink.datastream import StreamExecutionEnvironment","from pyflink.table import TableEnvironment","from pyflink.table import EnvironmentSettings","from pyflink.table.types import DataTypes","from pyflink.table import TableDescriptor","from pyflink.table import Schema","from pyflink.table.formats.csv import Csv","from pyflink.table import ..."]}],"homepage":"https://flink.apache.org","github":null,"docs":null,"changelog":null,"pypi":"https://pypi.org/project/apache-flink/","npm":null,"openapi_spec":null,"status_page":null,"smithery":null,"compatibility":{"summary":{"python_range":"3.10–3.9","success_rate":40,"avg_install_s":28.8,"avg_import_s":0.24,"wheel_type":"sdist"},"url":"https://checklist.day/v1/registry/apache-flink/compatibility"}}