Popular GitHub Repositories for Flink

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

A Scala feature transformation library for data science and machine learning

Machine learning library of Apache Flink

??DatalinkX异构数据源之间的数据同步系统，支持海量数据的增量或全量同步，同时支持HTTP、Oracle、MySQL、ES等数据源之间的数据流转，支持中间transform算子如SQL算子、大模型算子，底层依赖Flink、Seatunnel引擎，提供流转任务管理、任务级联配置、任务日志采集等功能??

Dataset Batch(offline) Reinforcement Learning for recommender system

Examples for Deep Learning/Feature Store/Spark/Flink/Hive/Kafka jobs and Jupyter notebooks on Hops

Recommender system based on Flink and Reinforcement Learning

A general Inference API based on two of the most popular Big Data processing engines: Apache Spark and Apache Flink

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

Streaming machine learning using PyTorch, Flink, and ONNX

Generic Model Serving Implementation leveraging Flink

在原作者（SplitfireUptown）datablinkx项目基础上进行了扩展，1.添加用户管理模块datalinkx-security，2.添加DeepSeek大模型模块datalinkx-deepseek

An example of Twitter realtime analysis with Kubernetes, Flink, Kafka, Kafka Connect, Cassandra, Elasticsearch/Kibana, Docker, Sentiment Analysis, Xgboost and Websockets

How to use ONNX models on Flink streams.

Speculative model serving with Flink

Use xgboost model to score data on Flink's datastream