apache-flink
There are 252 repositories under apache-flink topic.
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.
nielsbasjes/yauaa
Yet Another UserAgent Analyzer
TouK/nussknacker
Low-code tool for automating actions on real time data | Stream processing for the users.
GoogleCloudPlatform/flink-on-k8s-operator
[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
alibaba/feathub
FeatHub - A stream-batch unified feature store for real-time machine learning
streamnative/pulsar-flink
Elastic data processing with Apache Pulsar and Apache Flink
raystack/dagger
Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
dbs-leipzig/gradoop
Distributed Temporal Graph Analytics with Apache Flink
knaufk/flink-faker
A data generator source connector for Flink SQL based on data-faker.
FlinkML/flink-tensorflow
flink-tensorflow - TensorFlow support for Apache Flink
spotify/flink-on-k8s-operator
Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
ottogroup/flink-spector
Framework for Apache Flink unit tests
Chabane/bigdata-playground
A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL
ing-bank/flink-deployer
A tool that help automate deployment to an Apache Flink cluster
pdaodao/fiflow
flink-sql 在 flink 上运行 sql 和 构建数据流的平台 基于 apache flink 1.10.0
josephmachado/beginner_de_project_stream
Simple stream processing pipeline
FlinkML/flink-jpmml
flink-jpmml is a fresh-made library for dynamic real time machine learning predictions built on top of PMML standard models and Apache Flink streaming engine
getindata/dbt-flink-adapter
Adapter for dbt that executes dbt pipelines on Apache Flink
streamnative/awesome-pulsar
A curated list of Pulsar tools, integrations and resources.
seznam/euphoria
Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model which can express both batch and stream transformations.
twalthr/flink-api-examples
Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.
abeltavares/real-time-data-pipeline
📡 Real-time data pipeline with Kafka, Flink, Iceberg, Trino, MinIO, and Superset. Ideal for learning data systems.
aws-samples/amazon-kinesis-data-analytics-flink-starter-kit
Amazon Kinesis Data Analytics Flink Starter Kit helps you with the development of Flink Application with Kinesis Stream as a source and Amazon S3 as a sink. This demonstrates the use of Session Window with AggregateFunction.
realtimedatalake/rtdl
rtdl makes it easy to build and maintain a real-time data lake
airscholar/FlinkCommerce
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, and Postgres
garystafford/streaming-sales-generator
Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python
ververica/jupyter-vvp
Jupyter Integration for Flink SQL via Ververica Platform
raycad/stream-processing
Stream processing guidelines and examples using Apache Flink and Apache Spark
GMAP/DSPBench
A suite of benchmark applications for distributed data stream processing systems
build-on-aws/prioritizing-event-processing-with-apache-kafka
Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.
confluentinc/vscode
Confluent for Visual Studio Code
gordonmurray/apache_flink_and_docker_compose
A complete real-time Change Data Capture (CDC) pipeline using Apache Flink, MariaDB, and Docker Compose. This project demonstrates how to build a modern streaming analytics system that processes database changes in real-time.
cyberdelia/flink-kotlin
Kotlin support for Apache Flink
oceanbase/flink-connector-oceanbase
Apache Flink Connectors for OceanBase.
sanderploegsma/flink-k8s
Example Apache Flink cluster on Kubernetes
tj---/iceberg-demo
A sample implementation of stream writes to an Iceberg table on GCS using Flink and reading it using Trino