flink-sql

The Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.

sql stream-processing apache-flink flink flink-sql

Updated Nov 7, 2022
Dockerfile

threeknowbigdata / flink_second_understand

Star 756

该仓库专注于让读者秒懂Flink组件,包含Flink实战代码和文档、200个Flink教程知识点,Flink Datastream、Flink Table、Flink Window、Flink State、Flink Checkpoint、Flink Metrics、Flink Memory、Flink on standalone /yarn/k8s、Flink SQL、Flink CEP、Flink CDC、Flink UDF、PyFlink、Flink新特性、Flink Partition、Flink Memory等知识点。详细链接请看:https ://mp.weixin.qq.com/mp /appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=g...

flink-elasticsearch2-connector flink-dataset flink-kafka flink-cep flink-streaming flink-sql flink-table pyflink flink-cdc flink-udf flink-window flink-state

Updated Jun 14, 2024
Java

flowerfine / scaleph

Star 391

Open data platform based on Kubernetes. Scaleph supports SeaTunnel、Flink and Doris backended by SeaTunnel on Flink engine、Flink Kubernetes Operator and Doris operator.

dataops data-platform flink dag doris flink-sql seatunnel flink-sql-gateway flink-kubernetes flink-kubernetes-operator doris-operator doris-manager

Updated Jul 9, 2025
Java

jeff-zou / flink-connector-redis

Star 254

Asynchronous flink connector based on the Lettuce, supporting sql join and sink, query caching and debugging.

redis join flink lettuce flink-connector flink-connector-redis flink-sql

Updated Apr 15, 2025
Java

knaufk / flink-faker

Star 230

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

apache-flink flink flink-sql

Updated Jul 24, 2023
Java

getindata / flink-http-connector

Star 192

Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.

java flink data-streaming flink-stream-processing flink-sql

Updated Oct 18, 2025
Java

Real-time-Data-Warehouse

izhangzhihao / Real-time-Data-Warehouse

Star 116

Real-time Data Warehouse with Apache Flink & Apache Kafka & Apache Hudi

elasticsearch sql kafka spark hoodie data-warehouse delta flink cdc change-data-capture iceberg datalake debezium spark-sql data-warehousing hudi delta-lake deltalake flink-sql real-time-data-warehouse

Updated Dec 15, 2023
Dockerfile

LittleFall / flink-tidb-rdw

Star 83

A sample of Flink TiDB Realtime Datawarehouse.

mysql tidb flink-sql

Updated May 19, 2021

xuanbo / flink-cdc

Star 65

CDC(变化数据捕获)实时同步方案,秒级延迟。

flink debezium flink-sql flink-cdc

Updated Jan 28, 2022
Java

twalthr / flink-api-examples

Star 64

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

stream-processing data-engineering apache-flink flink flink-examples flink-sql

Updated Sep 26, 2023
Java

thestyleofme / flink-explore

Star 50

基于canal/kafka conenct的mysql/oracle数据实时同步、flink rest api、flink sql以及udf

flink kafka-connector canal flink-sql flink-api

Updated Sep 8, 2022
Scala

collabH / flink-connector-kudu

Star 45

基于Apache-bahir-kudu-connector的flink-connector-kudu,支持Flink1.11.x DynamicTableSource/Sink,支持Range分区等

kudu flink datastream flink-sql kudu-connector flink-dynamic-source

Updated May 30, 2023
Java

factorhouse / factorhouse-local

Star 45

Docker Compose environments for demonstrating modern data platform architectures using Kafka, Flink, Spark, Iceberg, Pinot + Kpow & Flex by Factor House