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

Discover Flink clusters on Hadoop YARN for Prometheus

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.

🚀 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. 🛣️

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.

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

A tool for extracting and integrating data from heterogeneous data sources

Simple example for access count in Apache logs using Apache Flink