Dataset Batch(offline) Reinforcement Learning for recommender system

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

Jupyter Integration for Flink SQL via Ververica Platform

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

Apache Flink (Pyflink) and Related Projects

Frequently Asked Questions about PyFlink

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

Discover Flink clusters on Hadoop YARN for Prometheus

🚀 Traffic Sentinel: A scalable IoT system using Fog nodes and Apache Flink to process 📷 IP camera streams, powered by YOLO for intelligent 🚗 traffic monitoring on highways. 🛣️

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

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

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

Robot is a framework base on flink below v1.5, serve for 'oshit team', develop in python3.6。

Tasks API for Stateful Functions on Flink

A dbt adapter for Decodable

Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).

Apache Paimon Python The Python implementation of Apache Paimon.

How to build a complete Data Platform -> Here

Command line utility to interact with Flink job manager using the monitoring REST API

A python client to deploy JVM flink applications to a remote cluster