Ecosyste.ms: Repos
An open API service providing repository metadata for many open source software ecosystems.
GitHub topics: flink-sql
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.
Language: Java - Size: 20.5 MB - Last synced: about 9 hours ago - Pushed: about 11 hours ago - Stars: 341 - Forks: 99
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.
Language: HCL - Size: 10.3 MB - Last synced: 4 days ago - Pushed: 4 days ago - Stars: 35 - Forks: 20
ev2900/Flink_Late_Arriving_Date_Event_Order
Helps explain how Flink handles late arriving data and the effects on message order
Language: Python - Size: 351 KB - Last synced: 5 days ago - Pushed: 5 days ago - Stars: 2 - Forks: 0
jeff-zou/flink-connector-redis
Asynchronous flink connector based on the Lettuce, supporting sql join and sink, query caching and debugging.
Language: Java - Size: 722 KB - Last synced: 21 days ago - Pushed: 21 days ago - Stars: 197 - Forks: 73
getindata/flink-http-connector
Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
Language: Java - Size: 533 KB - Last synced: 22 days ago - Pushed: 22 days ago - Stars: 126 - Forks: 36
wuquegongzi/hlink
基于flink (SQL)的特征加工平台
Language: Java - Size: 137 MB - Last synced: 24 days ago - Pushed: about 3 years ago - Stars: 8 - Forks: 5
zhp8341/flink-streaming-platform-web
基于flink的实时流计算web平台
Language: Java - Size: 10.5 MB - Last synced: 27 days ago - Pushed: 7 months ago - Stars: 1,758 - Forks: 673
Airblader/blog-imap
Language: Shell - Size: 64.5 KB - Last synced: 26 days ago - Pushed: over 2 years ago - Stars: 3 - Forks: 4
flowerfine/sakura
Another Flink sql catalog implementation
Language: Java - Size: 2.34 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 1 - Forks: 0
twalthr/flink-api-examples
Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.
Language: Java - Size: 31.3 KB - Last synced: about 2 months ago - Pushed: 8 months ago - Stars: 43 - Forks: 17
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.
Language: Kotlin - Size: 77.1 KB - Last synced: about 2 months ago - Pushed: 4 months ago - Stars: 1 - Forks: 0
ev2900/Flink_Kinesis_Data_Analytics
Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).
Language: Python - Size: 17.3 MB - Last synced: about 2 months ago - Pushed: 6 months ago - Stars: 10 - Forks: 10
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.
Language: Dockerfile - Size: 14.1 MB - Last synced: 3 months ago - Pushed: over 1 year ago - Stars: 798 - Forks: 195
birdLark/LarkMidTable
LarkMidTable 是一站式开源的数据中台,实现中台的 基础建设,数据治理,数据开发,监控告警,数据服务,数据的可视化,实现高效赋能数据前台并提供数据服务的产品。
Language: Java - Size: 81.7 MB - Last synced: 3 months ago - Pushed: 10 months ago - Stars: 1,578 - Forks: 540
knaufk/flink-faker
A data generator source connector for Flink SQL based on data-faker.
Language: Java - Size: 1.81 MB - Last synced: 3 months ago - Pushed: 11 months ago - Stars: 194 - Forks: 53
izhangzhihao/Real-time-Data-Warehouse
Real-time Data Warehouse with Apache Flink & Apache Kafka & Apache Hudi
Language: Dockerfile - Size: 106 KB - Last synced: 3 months ago - Pushed: 6 months ago - Stars: 95 - Forks: 40
nkonev/flink-connector-clickhouse Fork of itinycheng/flink-connector-clickhouse
Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
Language: Java - Size: 273 KB - Last synced: about 2 months ago - Pushed: 4 months ago - Stars: 0 - Forks: 0
camilesing/Flink-SQL-Helper-VSCode
Flink SQL extension for Visual Studio Code
Language: TypeScript - Size: 12.6 MB - Last synced: about 1 month ago - Pushed: 7 months ago - Stars: 11 - Forks: 2
SharpData/SharpETL
Write ETL using your favorite SQL dialects
Language: Scala - Size: 3.37 MB - Last synced: 5 months ago - Pushed: 5 months ago - Stars: 36 - Forks: 5
AhmetFurkanDEMIR/Flink-Example
Flink Example
Language: Scala - Size: 5.6 MB - Last synced: 27 days ago - Pushed: 7 months ago - Stars: 11 - Forks: 0
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
Language: Java - Size: 58.6 MB - Last synced: 7 months ago - Pushed: almost 2 years ago - Stars: 586 - Forks: 159
MyLanPangzi/flink-demo
Flink Demo
Language: Java - Size: 1.63 MB - Last synced: 3 months ago - Pushed: 11 months ago - Stars: 42 - Forks: 14
jwsmai/ScalaTools
This project provides Apache Spark SQL, Flink DataStream API examples in Scala language
Language: Scala - Size: 3.19 MB - Last synced: 10 months ago - Pushed: 10 months ago - Stars: 0 - Forks: 0
swtwsk/flink-array-row-bug
Language: Java - Size: 5.86 KB - Last synced: 10 months ago - Pushed: almost 2 years ago - Stars: 0 - Forks: 0
collabH/flink-connector-kudu
基于Apache-bahir-kudu-connector的flink-connector-kudu,支持Flink1.11.x DynamicTableSource/Sink,支持Range分区等
Language: Java - Size: 141 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 40 - Forks: 23
jcaberio/sentinel-flink-connector-featurestore
Flink connector for writing data into Amazon SageMaker Feature Store
Language: Java - Size: 0 Bytes - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0
getindata/flink-ververica-catalog-proxy
Proxy to the internal Ververica Catalog via Ververica REST Api
Language: Java - Size: 82 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0
pangliang/flink-connector-futuopend
Language: Java - Size: 24.4 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 1 - Forks: 0
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
Language: TypeScript - Size: 210 KB - Last synced: over 1 year ago - Pushed: over 1 year ago - Stars: 1 - Forks: 0
LittleFall/flink-tidb-rdw
A sample of Flink TiDB Realtime Datawarehouse.
Size: 85.4 MB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 76 - Forks: 24
xuanbo/flink-cdc
CDC(变化数据捕获)实时同步方案,秒级延迟。
Language: Java - Size: 1.6 MB - Last synced: over 1 year ago - Pushed: over 2 years ago - Stars: 26 - Forks: 17
thestyleofme/flink-explore
基于canal/kafka conenct的mysql/oracle数据实时同步、flink rest api、flink sql以及udf
Language: Scala - Size: 7.24 MB - Last synced: over 1 year ago - Pushed: over 1 year ago - Stars: 50 - Forks: 18
morsapaes/flink-sql-pulsar 📦
Self-contained demo using Flink SQL and Apache Pulsar to build a simple analytics pipeline. All you need is Docker! 🐳
Language: Dockerfile - Size: 15.6 KB - Last synced: over 1 year ago - Pushed: about 3 years ago - Stars: 5 - Forks: 6
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:
Language: Dockerfile - Size: 75.2 KB - Last synced: over 1 year ago - Pushed: about 3 years ago - Stars: 16 - Forks: 25
potamois/flink-fuse
A tiny Flink-SQL job execution shim.
Language: Java - Size: 43.9 KB - Last synced: over 1 year ago - Pushed: over 1 year ago - Stars: 3 - Forks: 3
dyrnq/cdc-vagrant
CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.
Language: Shell - Size: 73.2 KB - Last synced: over 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
zBrainiac/StreamAnalytics
Language: Java - Size: 2.94 MB - Last synced: over 1 year ago - Pushed: over 1 year ago - Stars: 3 - Forks: 2
librity/rtjvm_flink
Rock The JVM - Apache Flink with Scala
Language: Scala - Size: 17.6 MB - Last synced: over 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
chethanuk/flink-cluster-template
Flink K8s Cluster Template
Language: Python - Size: 105 KB - Last synced: about 1 year ago - Pushed: over 1 year ago - Stars: 0 - Forks: 0
slankka/flinksql-executor
A xml driven flinksql executor, for rapid development, testing, debuging, realtime compute platform, etc
Language: Java - Size: 6.84 KB - Last synced: over 1 year ago - Pushed: about 2 years ago - Stars: 0 - Forks: 0
bekisz/flink-pi
Simple Flink example to use Flink DataStream and SQL APIs for solving the same and simple problem. Estimating the value Pi more and more precisely via Monte-Carlo trials.
Language: Scala - Size: 49.8 KB - Last synced: over 1 year ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0
dalongm/flink-table-demo
Flink 1.10.0 sink method demo
Language: Java - Size: 11.7 KB - Last synced: over 1 year ago - Pushed: almost 2 years ago - Stars: 1 - Forks: 1