GitHub topics: pyflink
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: 4 days ago - Pushed at: 4 days ago - Stars: 5 - Forks: 0
AhmetFurkanDEMIR/Sahibinden-Data-Engineering-Technical-Case-Study
Sahibinden.com Data Engineering Technical Case Study
Language: Python - Size: 2.89 MB - Last synced at: 1 day ago - Pushed at: 3 months ago - Stars: 3 - Forks: 0
decodableco/examples
🌟 Examples of use cases that utilize Decodable, as well as demos for related open-source projects such as Apache Flink, Debezium, and Postgres.
Language: Java - Size: 19.9 MB - Last synced at: about 2 months ago - Pushed at: about 2 months ago - Stars: 71 - Forks: 34
huseinzol05/Gather-Deployment 📦
Gathers Python deployment, infrastructure and practices.
Language: Jupyter Notebook - Size: 146 MB - Last synced at: 2 months ago - Pushed at: almost 2 years ago - Stars: 352 - Forks: 99
daniel-dqsdatalabs/bigdata-projects
Big Data Stack
Language: Python - Size: 368 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 0 - Forks: 0
jaehyeon-kim/flink-demos
Apache Flink (Pyflink) and Related Projects
Language: Python - Size: 2.18 MB - Last synced at: 2 months ago - Pushed at: 12 months ago - Stars: 35 - Forks: 12
tashi-2004/Apache-Flink-Spark-Data-Streaming
This project showcases a real-time data streaming pipeline using Apache Flink, Apache Spark, and Grafana. It streams data, stores it in Parquet format, and performs aggregations for insights, with seamless visualization via Grafana dashboards.
Language: Python - Size: 62.6 MB - Last synced at: 2 months ago - Pushed at: 4 months ago - Stars: 0 - Forks: 0
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: 3 months ago - Pushed at: 6 months ago - Stars: 1 - 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: 12 months ago - Pushed at: 12 months ago - Stars: 646 - Forks: 174
eli64s/pyflink-poc
PyFlink data stream processing utilities 🐿
Language: Python - Size: 32.2 KB - Last synced at: about 2 months ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 1
kxu913/podcase
it's a simple podcase app poc.
Language: Dart - Size: 43.6 MB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0
dianfu/pyflink-faq
Frequently Asked Questions about PyFlink
Language: Python - Size: 35.2 KB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 18 - Forks: 2
nanmu42/PyFlink-in-Docker
Docker base image for Flink Python, using miniconda environment
Language: Shell - Size: 9.77 KB - Last synced at: about 2 months ago - Pushed at: almost 4 years ago - Stars: 3 - Forks: 2
morsapaes/pyflink-nlp 📦
Self-contained demo using PyFlink with Gensim+spaCy to find topics in the Flink User Mailing List. All you need is Docker! 🐳
Language: Python - Size: 252 KB - Last synced at: over 2 years ago - Pushed at: over 3 years ago - Stars: 20 - Forks: 15
nicofretti/flink_experiment
First project with Apache Flink (a framework for distributed stream and batch data processing)
Language: Java - Size: 3.88 MB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
nbsps/SilvensnRecSys
Primary Recommender System: online[matching|ranking...](Flask|Vue) - nearline[model serving|real-time service](Flink|tensorflow serving|redis) - offline[feature engine|model training](Spark|Hdfs(Hbase)|tf)
Language: Python - Size: 57.4 MB - Last synced at: about 2 years ago - Pushed at: about 3 years ago - Stars: 7 - Forks: 6
ludekcizinsky/pl-stream-local
Implementation of the PLStream locally on macOS.
Language: Python - Size: 19.5 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0
