flink-sql
There are 52 repositories under flink-sql topic.
birdLark/LarkMidTable
LarkMidTable 是一站式开源的数据中台，实现中台的 基础建设，数据治理，数据开发，监控告警，数据服务，数据的可视化，实现高效赋能数据前台并提供数据服务的产品。
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.
twalthr/flink-api-examples
Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.
xuanbo/flink-cdc
CDC（变化数据捕获）实时同步方案，秒级延迟。
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
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:
camilesing/Flink-SQL-Helper-VSCode
Flink SQL extension for Visual Studio Code
AhmetFurkanDEMIR/Flink-Example
Flink Example
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
ev2900/Flink_Kinesis_Data_Analytics
Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).
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.
wuquegongzi/hlink
基于flink (SQL)的特征加工平台
morsapaes/flink-sql-pulsar
Self-contained demo using Flink SQL and Apache Pulsar to build a simple analytics pipeline. All you need is Docker! 🐳
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.
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
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.
flowerfine/sakura
Another Flink sql catalog implementation
getindata/flink-ververica-catalog-proxy
Proxy to the internal Ververica Catalog via Ververica REST Api
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.