flink-streaming
Here are 40 public repositories matching this topic...
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.
-
Updated
May 26, 2024 - Kotlin
Keyed Watermarks in Apache Flink
-
Updated
Apr 21, 2024 - Java
This project aimed at providing real-time click attribution and dynamic e-commerce insights.
-
Updated
Apr 14, 2024 - Python
Demo Flink and Kafka project to show how to react on tracking events in real-time and trigger offer for customer engagement based on campaign configurations. The project also utilizes the Broadcast State Pattern in order to update the rules (campaigns) at runtime without restarting the project, using a dedicated, low-frequency, Kafka topic.
-
Updated
Feb 15, 2024 - Java
Flink SQL connector for ClickHouse. Support ClickHouseCatalog and read/write primary data, maps, arrays to clickhouse.
-
Updated
Feb 11, 2024 - Java
This repository contains an Apache Flink application for real-time sales analytics built using Docker Compose to orchestrate the necessary infrastructure components, including Apache Flink, Elasticsearch, MySQL, and Postgres
-
Updated
Jan 6, 2024 - Java
Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).
-
Updated
Dec 4, 2023 - Python
Flink Example
-
Updated
Nov 19, 2023 - Scala
实时事件分析与决策引擎(Real-time event analysis and decision engine)
-
Updated
Oct 10, 2023 - Java
This project uses Apache Flink as a stream engine that consumes data from the File system or Kafka brokers and exposes metrics using Prometheus and Grafana, everything deployed on Kubernetes (minikube).
-
Updated
Sep 5, 2023 - Java
第四代大数据计算引擎Flink - 从入门到实战
-
Updated
Jun 3, 2023 - Java
Information Systems, Analysis and Design Class Projects (2022-23, Fall Semester)
-
Updated
Mar 1, 2023 - Java
Flink K8s Cluster Template
-
Updated
Sep 19, 2022 - Python
Starter templates for getting started with Apache Flink ( java-based stream processing library)
-
Updated
Aug 26, 2022 - Java
该仓库专注于让读者秒懂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=g…
-
Updated
Jul 3, 2022 - Java
Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink
-
Updated
Jul 1, 2022 - Scala
Improve this page
Add a description, image, and links to the flink-streaming topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the flink-streaming topic, visit your repo's landing page and select "manage topics."