flink-sql

Star

Here are 57 public repositories matching this topic...

Language:All

Filter by language

All57 Java26 Python9 Scala6 Dockerfile4 Shell3 TypeScript3 HCL1 Kotlin1

Sort:Most stars

Sort options

Most stars Fewest stars Most forks Fewest forks Recently updated Least recently updated

birdLark /LarkMidTable

Star2k

LarkMidTable 是一站式开源的数据中台，实现中台的基础建设，数据治理，数据开发，监控告警，数据服务，数据的可视化，实现高效赋能数据前台并提供数据服务的产品。

flink datax flink-sql flinkx flink-cdc seatunnel

UpdatedAug 20, 2023
Java

zhp8341 /flink-streaming-platform-web

Star1.9k

基于flink的实时流计算web平台

streaming sql flink flink-sql

UpdatedOct 28, 2025
Java

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

UpdatedNov 7, 2022
Dockerfile

threeknowbigdata /flink_second_understand

Star756

该仓库专注于让读者秒懂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

UpdatedJun 14, 2024
Java

flowerfine /scaleph

Star392

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

UpdatedJul 9, 2025
Java

jeff-zou /flink-connector-redis

Star254

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

UpdatedApr 15, 2025
Java

knaufk /flink-faker

Star231

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

apache-flink flink flink-sql

UpdatedJul 24, 2023
Java

getindata /flink-http-connector

Star193

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

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

UpdatedOct 27, 2025
Java

izhangzhihao /Real-time-Data-Warehouse

Star118

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

UpdatedDec 15, 2023
Dockerfile

LittleFall /flink-tidb-rdw

Star83

A sample of Flink TiDB Realtime Datawarehouse.

mysql tidb flink-sql

UpdatedMay 19, 2021

xuanbo /flink-cdc

Star65

CDC（变化数据捕获）实时同步方案，秒级延迟。

flink debezium flink-sql flink-cdc

UpdatedJan 28, 2022
Java

twalthr /flink-api-examples

Star65

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

UpdatedSep 26, 2023
Java

thestyleofme /flink-explore

Star50

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

flink kafka-connector canal flink-sql flink-api

UpdatedSep 8, 2022
Scala

factorhouse /factorhouse-local

Star46

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