camilesing/Flink-SQL-Helper-VSCode

Flink SQL extension for Visual Studio Code

Language: TypeScript - Size: 10.7 MB - Last synced at: about 19 hours ago - Pushed at: about 19 hours ago - Stars: 16 - Forks: 1

ev2900/Flink_Late_Arriving_Date_Event_Order

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

Language: Python - Size: 354 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 3 - Forks: 0

knaufk/flink-faker

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

Language: Java - Size: 1.81 MB - Last synced at: 1 day ago - Pushed at: almost 2 years ago - Stars: 224 - Forks: 58

confluentinc/flink-table-api-python-examples

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

Language: Python - Size: 58.6 KB - Last synced at: 24 days ago - Pushed at: 24 days ago - Stars: 16 - Forks: 4

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.

Language: Java - Size: 33.4 MB - Last synced at: 26 days ago - Pushed at: 26 days ago - Stars: 5 - Forks: 0

zhp8341/flink-streaming-platform-web

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

Language: Java - Size: 11.7 MB - Last synced at: about 1 month ago - Pushed at: 10 months ago - Stars: 1,836 - Forks: 686

getindata/flink-http-connector

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

Language: Java - Size: 684 KB - Last synced at: about 1 month ago - Pushed at: about 1 month ago - Stars: 181 - Forks: 48

birdLark/LarkMidTable

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

Language: Java - Size: 81.7 MB - Last synced at: about 2 months ago - Pushed at: almost 2 years ago - Stars: 1,930 - Forks: 593

confluentinc/flink-table-api-java-examples

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

Language: Java - Size: 134 KB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 11 - Forks: 6

jeff-zou/flink-connector-redis

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

Language: Java - Size: 844 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 237 - Forks: 88

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.9 MB - Last synced at: 3 months ago - Pushed at: 6 months ago - Stars: 379 - Forks: 108

izhangzhihao/Real-time-Data-Warehouse

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

Language: Dockerfile - Size: 106 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 113 - Forks: 44

AhmetFurkanDEMIR/Flink-Example

Flink Example

Language: Scala - Size: 5.6 MB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 15 - 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 at: 3 months ago - Pushed at: almost 2 years ago - Stars: 63 - Forks: 20

pneff93/stream-processing-playground

Repo to try out different stream processing technologies

Language: Java - Size: 296 KB - Last synced at: 4 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 1

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 at: 4 months ago - Pushed at: over 2 years ago - Stars: 879 - Forks: 202

Airblader/blog-imap

Language: Shell - Size: 64.5 KB - Last synced at: 3 months ago - Pushed at: almost 4 years ago - Stars: 5 - Forks: 4

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.

Language: Python - Size: 650 KB - Last synced at: 4 months ago - Pushed at: 7 months ago - Stars: 1 - Forks: 0

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: 150 KB - Last synced at: 4 months ago - Pushed at: 7 months 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: 142 KB - Last synced at: 3 months ago - Pushed at: about 2 years ago - Stars: 46 - Forks: 24

MyLanPangzi/flink-demo

Flink Demo

Language: Java - Size: 1.63 MB - Last synced at: 3 months ago - Pushed at: almost 2 years ago - Stars: 41 - Forks: 12

Hedeoer/edu_online

在线教育

Language: Java - Size: 126 KB - Last synced at: 11 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

flowerfine/sakura

Another Flink sql catalog implementation

Language: Java - Size: 2.35 MB - Last synced at: 11 months ago - Pushed at: 11 months ago - Stars: 1 - Forks: 0

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 at: 12 months ago - Pushed at: about 1 year ago - Stars: 4 - 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.7 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 646 - Forks: 174

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: 78.1 KB - Last synced at: 3 months ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0

wuquegongzi/hlink

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

Language: Java - Size: 137 MB - Last synced at: about 1 year ago - Pushed at: about 4 years ago - Stars: 8 - Forks: 5

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 at: 3 months ago - Pushed at: over 1 year ago - Stars: 10 - Forks: 11

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 at: about 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

SharpData/SharpETL

Write ETL using your favorite SQL dialects

Language: Scala - Size: 3.37 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 36 - Forks: 5

getindata/flink-ververica-catalog-proxy

Proxy to the internal Ververica Catalog via Ververica REST Api

Language: Java - Size: 82 KB - Last synced at: 8 days ago - Pushed at: about 2 years ago - Stars: 1 - Forks: 0

jwsmai/ScalaTools

This project provides Apache Spark SQL, Flink DataStream API examples in Scala language

Language: Scala - Size: 3.19 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

jcaberio/sentinel-flink-connector-featurestore

Flink connector for writing data into Amazon SageMaker Feature Store

Language: Java - Size: 0 Bytes - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0

librity/rtjvm_flink

Rock The JVM - Apache Flink with Scala

Language: Scala - Size: 17.6 MB - Last synced at: 4 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

pangliang/flink-connector-futuopend

Language: Java - Size: 24.4 KB - Last synced at: about 2 years ago - Pushed at: over 2 years 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 at: over 2 years ago - Pushed at: almost 3 years ago - Stars: 1 - Forks: 0

LittleFall/flink-tidb-rdw

A sample of Flink TiDB Realtime Datawarehouse.

Size: 85.4 MB - Last synced at: over 2 years ago - Pushed at: about 4 years ago - Stars: 76 - Forks: 24

xuanbo/flink-cdc

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

Language: Java - Size: 1.6 MB - Last synced at: over 2 years ago - Pushed at: over 3 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 at: over 2 years ago - Pushed at: almost 3 years 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 at: over 2 years ago - Pushed at: about 4 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 at: over 2 years ago - Pushed at: about 4 years ago - Stars: 16 - Forks: 25

potamois/flink-fuse

A tiny Flink-SQL job execution shim.

Language: Java - Size: 43.9 KB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 3

zBrainiac/StreamAnalytics

Language: Java - Size: 2.94 MB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 3 - Forks: 2

chethanuk/flink-cluster-template

Flink K8s Cluster Template

Language: Python - Size: 105 KB - Last synced at: about 2 years ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0

swtwsk/flink-array-row-bug

Language: Java - Size: 5.86 KB - Last synced at: 4 months ago - Pushed at: almost 3 years 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 at: over 2 years ago - Pushed at: over 3 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 at: over 2 years ago - Pushed at: about 4 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 at: over 2 years ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 1