dmlc / xgboost

Scalable, Portable and Distributed Gradient Boosting (GBDT, GBRT or GBM) Library, for Python, R, Java, Scala, C and more. Runs on single machine, Hadoop, Spark, Dask, Flink and DataFlow

apache / flink

Apache Flink

datavane / tis

Support agile Ontology DataOps Based on Flink, DataX and Flink-CDC with Web-UI

apache / zeppelin

Web-based notebook that enables data-driven, interactive data analytics and collaborative documents with SQL, Scala and more.

apache / hudi

Upserts, Deletes And Incremental Processing on Big Data.

apache / paimon

Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.

timeplus-io / proton

The fastest unified streaming SQL Engine in a single C++ binary. ⚡ Millisecond latency. 100+ GB/s throughput. Continuously compute stateful context from streams, logs, metrics, events, and CDC.

apache / streampark

The Open Control Plane for Real-Time Data

DataLinkDC / dinky

Dinky is a real-time data development platform based on Apache Flink, enabling agile data development, deployment and operation.

apache / amoro

Apache Amoro(incubating) is a Lakehouse management system built on open data lake formats.

lakesoul-io / LakeSoul

LakeSoul is an end-to-end, realtime cloud-native Lakehouse framework for fast data ingestion, concurrent updates, incremental analytics, multimodal data processing and vector search — powering next-generation BI and AI workloads.

confluentinc / examples

Apache Kafka, Apache Flink and Confluent Platform examples and demos

apache / flink-kubernetes-operator

Apache Flink Kubernetes Operator

nielsbasjes / yauaa

Yet Another UserAgent Analyzer

delta-io / delta

An open-source storage framework that enables building a Lakehouse architecture with compute engines including Spark, PrestoDB, Flink, Trino, and Hive and APIs

apache / flink-cdc

Flink CDC is a streaming data integration tool

water8394 / flink-recommandSystem-demo

:helicopter::rocket:基于Flink实现的商品实时推荐系统。flink统计商品热度，放入redis缓存，分析日志信息，将画像标签和实时记录放入Hbase。在用户发起推荐请求后，根据用户画像重排序热度榜，并结合协同过滤和标签两个推荐模块为新生成的榜单的每一个产品添加关联产品，最后返回新的用户列表。

DTStack / chunjun

A data integration framework

TouK / nussknacker

Low-code tool for automating actions on real time data | Stream processing for the users.

apache / flink-playgrounds

Apache Flink Playgrounds