Yet Another UserAgent Analyzer

Elastic data processing with Apache Pulsar and Apache Flink

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.

Distributed Temporal Graph Analytics with Apache Flink

A data generator source connector for Flink SQL based on data-faker.

Framework for Apache Flink unit tests

flink-sql 在 flink 上运行 sql 和 构建数据流的平台 基于 apache flink 1.10.0

Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model which can express both batch and stream transformations.

Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.

Amazon Kinesis Data Analytics Flink Starter Kit helps you with the development of Flink Application with Kinesis Stream as a source and Amazon S3 as a sink. This demonstrates the use of Session Window with AggregateFunction.

Stream processing guidelines and examples using Apache Flink and Apache Spark

This repository contains an Apache Flink application for real-time sales analytics built using Docker Compose to orchestrate the necessary infrastructure components, including Apache Flink, Elasticsearch, and Postgres

a suite of benchmark applications for distributed data stream processing systems

Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.

Sample project for Apache Flink with Streaming Engine and JDBC Sink

The Proxima platform.

A sample implementation of stream writes to an Iceberg table on GCS using Flink and reading it using Trino

Apache Flink Connectors for OceanBase.

Flink SQL 实战 -中文博客专栏

IMAP / SMTP connectors for Apache Flink®