flink

大数据知识仓库涉及到数据仓库建模、实时计算、大数据、数据中台、系统设计、Java、算法等。

More than 2000+ Data engineer interview questions.

Benchmarks for data processing systems: Pathway Live Data Framework, Spark, Flink, Kafka Streams

Dataset Batch(offline) Reinforcement Learning for recommender system

📈 A scalable, production-ready data pipeline for real-time streaming & batch processing, integrating Kafka, Spark, Airflow, AWS, Kubernetes, and MLflow. Supports end-to-end data ingestion, transformation, storage, monitoring, and AI/ML serving with CI/CD automation using Terraform & GitHub Actions.

Build, deploy, and orchestrate event-driven agents natively on Apache Flink® and Apache Kafka®

Feature demos, integration guides & hands-on labs/projects using Kpow, Flex, Kafka, Flink, Iceberg & more

This repository contains the ingredients for the Digital Twin Concept of Industry Fusion.

Apache Flink Demo Projects

AI agent skills for stream processing and event streaming

Jupyter Integration for Flink SQL via Ververica Platform

📚🧪 Traffic Sentinel is a learning-focused POC that explores a scalable IoT architecture using Fog nodes and Apache Flink to process 📷 IP camera streams, powered by YOLO for intelligent 🚗 traffic monitoring on highways. 🛣️

Discover Flink clusters on Hadoop YARN for Prometheus

Frequently Asked Questions about PyFlink

Track your vehicle's live location offline by using little more than a Raspberry Pi & a gps dongle, without expensive subscription services.

Apache Paimon Python The Python implementation of Apache Paimon.

Snapshot manager for Amazon Kinesis Data Analytics for Apache Flink helps the users to generate a snapshot on a periodic basis.

NextGen DataMotion Lineage

An end-to-end application for abstractive document summarization on top of TensorFlow, Flink-AI-Extended and Flink ML pipeline framework.

Demo projects and examples for Apache Flink Agents