pyflink

该仓库专注于让读者秒懂Flink组件，包含Flink实战代码和文档、200个Flink教程知识点，Flink Datastream、Flink Table、Flink Window、Flink State、Flink Checkpoint、Flink Metrics、Flink Memory、Flink on standalone /yarn/k8s、Flink SQL、Flink CEP、Flink CDC、Flink UDF、PyFlink、Flink新特性、Flink Partition、Flink Memory等知识点。详细链接请看：https ://mp.weixin.qq.com/mp /appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=g…

Gathers Python deployment, infrastructure and practices.

🌟 Examples of use cases that utilize Decodable, as well as demos for related open-source projects such as Apache Flink, Debezium, and Postgres.

Apache Flink examples in PyFlink and Kotlin: local Docker clusters, AWS Managed Flink deployments with Kafka, a Flink SQL cookbook, and worked exercises from Confluent courses and the Stream Processing with Flink book.

Plataforma bancária event-driven com antifraude em tempo real (PyFlink + XGBoost) e arranjo PIX completo (ISO 20022, mTLS). .NET 8, Clean Arch/CQRS, Kafka.

Frequently Asked Questions about PyFlink

Self-contained demo using PyFlink with Gensim+spaCy to find topics in the Flink User Mailing List. All you need is Docker! 🐳

Primary Recommender System: online[matching|ranking...](Flask|Vue) - nearline[model serving|real-time service](Flink|tensorflow serving|redis) - offline[feature engine|model training](Spark|Hdfs(Hbase)|tf)

Examples of Apache Flink® v2.1 applications showcasing the DataStream API, Table API in Java and Python, and Flink SQL, featuring AWS, GitHub, Terraform, Streamlit, and Apache Iceberg.

Python Practices 🐙 offers step-by-step Python exercises, real-world examples, and best coding standards from fundamentals to SOLID OOP for practical, scalable learning and growth.

Real-time mobility data platform for Casablanca: Kafka ingestion, PyFlink + Spark processing, Bronze-Silver-Gold warehouse on PostgreSQL/PostGIS, Grafana dashboards.

Sahibinden.com Data Engineering Technical Case Study

Real-time crypto analytics platform built with Kafka, Flink, ClickHouse and Iceberg.

it's a simple podcase app poc.

Docker base image for Flink Python, using miniconda environment

A Makeshift data infrastructure setup for datafirstjobs.com.

First project with Apache Flink (a framework for distributed stream and batch data processing)

A real-time social media comment analysis platform built with microservices, .NET, PyFlink, and Kafka.

Real-time data streaming using Apache Kafka, PyFlink and PostgreSQL.

Modern Flink 2.x + Kafka 4.x + Iceberg lakehouse demos with SQL, PyFlink, and Java.