flink-stream-processing
There are 121 repositories under flink-stream-processing topic.
czy006/FlinkClub
这是我自己的Flink中文社区翻译稿存储仓库，用于提供给需要朋友进行二次创作。同时提供Flink一些课外的相关知识文档供大家学习
streamnative/pulsar-flink
Elastic data processing with Apache Pulsar and Apache Flink
godaai/flink-book-zh
Flink Tutorial Project
getindata/flink-http-connector
Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
mickey0524/flink-streaming-source-analysis
flink 流处理源码分析
TU-Berlin-DIMA/scotty-window-processor
This repository provides Scotty, a framework for efficient window aggregations for out-of-order Stream Processing.
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.
microsoft/flink-on-azure
Examples of Flink on Azure
mikeroyal/Apache-Flink-Guide
Apache Flink Guide
aws-samples/amazon-managed-service-for-apache-flink-examples
Collection of code examples for Amazon Managed Service for Apache Flink
zlzhang0122/flink-in-action
基于Flink的批流处理实战案例
Anant/Cassandra.Realtime
Different ways to process data into Cassandra in realtime with technologies such as Kafka, Spark, Akka, Flink
cjermain/flink-onnx-pytorch
Streaming machine learning using PyTorch, Flink, and ONNX
hey-johnnypark/apache-flink-jdbc-streaming
Sample project for Apache Flink with Streaming Engine and JDBC Sink
aws-samples/amazon-kinesis-data-analytics-flink-benchmarking-utility
Amazon Managed Service for Apache Flink Benchmarking Utility helps with capacity planning, integration testing, and benchmarking of Amazon Managed Service for Apache Flink applications.
BrooksIan/Flink2Kafka
A Flink applcation that demonstrates reading and writing to/from Apache Kafka with Apache Flink
tj---/iceberg-demo
A sample implementation of stream writes to an Iceberg table on GCS using Flink and reading it using Trino
sergio11/traffic_sentinel_architecture
🚀 Traffic Sentinel: A scalable IoT system using Fog nodes and Apache Flink to process 📷 IP camera streams, powered by YOLO for intelligent 🚗 traffic monitoring on highways. 🛣️
aws-samples/amazon-kinesis-data-analytics-blueprints
Kinesis Data Analytics Blueprints are a curated collection of Apache Flink applications. Each blueprint will walk you through how to solve a practical problem related to stream processing using Apache Flink. These blueprints can be leveraged to create more complex applications to solve your business challenges in Apache Flink.
AhmetFurkanDEMIR/Flink-Example
Flink Example
innogames/flink-real-time-crm
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.
galgus/flink-connector-http
Flink HTTP Sink Connector
ev2900/Flink_Kinesis_Data_Analytics
Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).
riferrei/is-using-kop-a-good-idea
Is using KoP (Kafka-On-Pulsar) a good idea? Use the scenarios implemented in this repository to check whether Pulsar with KoP enabled is a good fit for your most common Kafka workloads.
Adsizzlerlabs/mangolaa-streams-processing-flink
Stream processing for the Mangolaa platform using Apache Kafka, Apache Flink, Java 8 and Lombok
eBay/flink-kudu-streaming-connector
A flink source connector to provide the continuous, incremental and streaming events from Kudu tables
fediazgon/flink-vehicle-telematics
Stream processing of simulated on-vehicle sensors data
ankushs92/apache-flink-aggregations-clickstreams
Count clicks in an unbounded clickstream over a Time window using Apache Flink's DataStream API
aws-samples/dynamic-rules-engine
The Dynamic Rules Engine is a serverless application that enables real-time evaluation of rules against sensor data, leveraging AWS Kinesis Data Streams, Amazon Managed Service for Apache Flink, and AWS Lambda.
mikeroyal/Apache-Beam-Guide
Apache Beam Guide
thomas-chauvet/predict-xgboost-flink
Use xgboost model to score data on Flink's datastream
AndyXGWang/B2C-User-Profile-Project
基于Flink流处理的动态实时亿级电商全端用户画像系统
arkady-emelyanov/toy-data-platform
Toy data platform for a company that provides web analytics
crate/cratedb-flink-jobs
This repository accompanies the article "Build a data ingestion pipeline using Kafka, Flink, and CrateDB" and the "CrateDB Community Day #2".
ehabqadah/Spark_Streaming_vs_Flink
A Comparative Evaluation of Spark and Flink Stream Processing.
aws-samples/amazon-managed-service-for-apache-flink-taxi-consumer
Sample Apache Flink application that can be deployed to Amazon Managed Service for Apache Flink. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to an Amazon OpenSearch Service cluster for visualization with Dashboard.