flink-sql

zhp8341/flink-streaming-platform-web

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

ververica/flink-sql-cookbook

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.

threeknowbigdata/flink_second_understand

该仓库专注于让读者秒懂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=getalbum&album_id=2038088622687469575#wechat_redirect

flowerfine/scaleph

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

jeff-zou/flink-connector-redis

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

knaufk/flink-faker

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

getindata/flink-http-connector

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

izhangzhihao/Real-time-Data-Warehouse

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

LittleFall/flink-tidb-rdw

A sample of Flink TiDB Realtime Datawarehouse.

xuanbo/flink-cdc

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

twalthr/flink-api-examples

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

thestyleofme/flink-explore

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

collabH/flink-connector-kudu

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

MyLanPangzi/flink-demo

Flink Demo

factorhouse/factorhouse-local

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

SharpData/SharpETL

Write ETL using your favorite SQL dialects

morsapaes/flink-sql-CDC

Self-contained demo using Flink SQL and Debezium to build a CDC-based analytics pipeline. All you need is Docker! :whale:

AhmetFurkanDEMIR/Flink-Example

Flink Example

camilesing/Flink-SQL-Helper-VSCode

Flink SQL extension for Visual Studio Code

confluentinc/flink-table-api-python-examples

Python Examples for running Apache Flink® Table API on Confluent Cloud

confluentinc/flink-table-api-java-examples

Java Examples for running Apache Flink® Table API on Confluent Cloud

confluentinc/demo-database-modernization

This demo shows how to stream data to cloud databases with Confluent. It includes fully-managed connectors (Oracle CDC, RabbitMQ, MongoDB Atlas), ksqlDB/Flink SQL as stream processing engine.

ev2900/Flink_Kinesis_Data_Analytics

Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).

anshan89/hlink

基于flink (SQL)的特征加工平台

j3-signalroom/apache_flink-kickstarter

Examples of Apache Flink® applications showcasing the DataStream API, Table API in Java and Python, and Flink SQL, featuring AWS, GitHub, Terraform, Streamlit, and Apache Iceberg.

mcagriaktas/kafka-lab

End-to-end Kafka ecosystem lab: streaming, monitoring, connectors, security and more.

morsapaes/flink-sql-pulsar

Self-contained demo using Flink SQL and Apache Pulsar to build a simple analytics pipeline. All you need is Docker! 🐳

Airblader/blog-imap

ev2900/Flink_Late_Arriving_Date_Event_Order

Helps explain how Flink handles late arriving data and the effects on message order

linsoss/flink-sql-fuse

A tiny Flink SQL runtime shim

yangjunhan/monaco-editor-lsp-client

Integrate monaco-languageclient with a Flink SQL LSP language server in Angular! Check out the Flink SQL web extension worker: https://www.npmjs.com/package/flink-sql-language-server

zBrainiac/StreamAnalytics

nkonev/flink-pipe

A [single|uber|fat] jar standalone Apache Flink connected to PostgreSQL via Ververica CDC connector. Usage Flink SQL to replicate data from PostgreSQL to Elasticsearch/something else.

hpgrahsl/current24-udf-examples

Examples Repo for my Current'24 talk "So you want to write a UDF for Flink?"

j3-signalroom/supercharge_streamlit-apache_flink

Engaging, interactive visualizations crafted with Streamlit, seamlessly powered by Apache Flink in batch mode to reveal deep insights from data.